Skip to content

Commit 48d92f6

Browse files
committed
[core] Publish ODC partition state changes
1 parent e9a7e89 commit 48d92f6

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

core/integration/odc/plugin.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -259,12 +259,16 @@ func (p *Plugin) queryPartitionStatus() {
259259
Info("ODC Partition state changed")
260260

261261
payload := map[string]interface{}{
262-
"odcStatus": &response,
262+
"oldState": existingPartition.State,
263+
"newState": partitionInfo.State,
264+
"partitionId": partitionInfo.PartitionId.String(),
265+
"ddsSessionId": partitionInfo.DdsSessionId,
266+
"ddsSessionStatus": partitionInfo.DdsSessionStatus,
263267
}
264268
payloadJson, _ := json.Marshal(payload)
265269

266270
the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{
267-
Name: "odc.queryPartitionStatus",
271+
Name: "odc.partitionStateChanged",
268272
EnvironmentId: id.String(),
269273
Payload: string(payloadJson[:]),
270274
})

0 commit comments

Comments
 (0)