diff --git a/core/integration/dcs/plugin.go b/core/integration/dcs/plugin.go index 7ad8e4ad..5a9898d3 100644 --- a/core/integration/dcs/plugin.go +++ b/core/integration/dcs/plugin.go @@ -828,6 +828,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -864,6 +865,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -900,6 +902,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -927,6 +930,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { detPayload := map[string]interface{}{} _ = copier.Copy(&detPayload, payload) detPayload["dcsEvent"] = dcsEvent + detPayload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] detPayloadJson, _ := json.Marshal(detPayload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ @@ -1497,6 +1501,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -1534,6 +1539,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -1571,6 +1577,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -1600,6 +1607,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { detPayload := map[string]interface{}{} _ = copier.Copy(&detPayload, payload) detPayload["dcsEvent"] = dcsEvent + detPayload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] detPayloadJson, _ := json.Marshal(detPayload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ @@ -2045,6 +2053,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -2082,6 +2091,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { payload["detector"] = ecsDet payload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] payloadJson, _ = json.Marshal(payload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{ Name: call.GetName(), @@ -2111,6 +2121,7 @@ func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{}) { detPayload := map[string]interface{}{} _ = copier.Copy(&detPayload, payload) detPayload["dcsEvent"] = dcsEvent + payload["state"] = dcspb.DetectorState_name[int32(dcsEvent.GetState())] detPayloadJson, _ := json.Marshal(detPayload) the.EventWriterWithTopic(TOPIC).WriteEvent(&pb.Ev_IntegratedServiceEvent{