Skip to content

Commit 8ccaf59

Browse files
author
Michal Tichák
committed
[odc] plumbing for expendable and rmsjobid in odcdevice
1 parent f5f0e16 commit 8ccaf59

File tree

1 file changed

+15
-11
lines changed

1 file changed

+15
-11
lines changed

core/integration/odc/plugin.go

Lines changed: 15 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -110,12 +110,14 @@ type OdcPartitionInfo struct {
110110
}
111111

112112
type OdcDevice struct {
113-
TaskId string `json:"taskId"`
114-
State string `json:"state"`
115-
EcsState sm.State `json:"ecsState"`
116-
Path string `json:"path"`
117-
Ignored bool `json:"ignored"`
118-
Host string `json:"host"`
113+
TaskId string `json:"taskId"`
114+
State string `json:"state"`
115+
EcsState sm.State `json:"ecsState"`
116+
Path string `json:"path"`
117+
Ignored bool `json:"ignored"`
118+
Host string `json:"host"`
119+
Expendable bool `json:"expendable"`
120+
Rmsjobid string `json :"rmsjobid"`
119121
}
120122

121123
type partitionStateChangedEventPayload struct {
@@ -258,11 +260,13 @@ func (p *Plugin) queryPartitionStatus() {
258260
odcPartInfoSlice[idx].Devices = make(map[OdcDeviceId]*OdcDevice, len(odcPartStateRep.Devices))
259261
for _, device := range odcPartStateRep.Devices {
260262
odcPartInfoSlice[idx].Devices[OdcDeviceId(device.Id)] = &OdcDevice{
261-
TaskId: strconv.FormatUint(device.Id, 10),
262-
State: device.State,
263-
Path: device.Path,
264-
Ignored: device.Ignored,
265-
Host: device.Host,
263+
TaskId: strconv.FormatUint(device.Id, 10),
264+
State: device.State,
265+
Path: device.Path,
266+
Ignored: device.Ignored,
267+
Host: device.Host,
268+
Expendable: device.Expendable,
269+
Rmsjobid: device.Rmsjobid,
266270
}
267271
}
268272
}(i, id)

0 commit comments

Comments
 (0)