diff --git a/pulsar/common/kdr/datastructures.go b/pulsar/common/kdr/datastructures.go index 4b21108..bd55c66 100644 --- a/pulsar/common/kdr/datastructures.go +++ b/pulsar/common/kdr/datastructures.go @@ -7,6 +7,10 @@ import ( "go.uber.org/zap" ) +const ( + RuntimeIncidentIngesterOnFinishedMessageTypeProp = "RuntimeIncidentIngesterOnFinishedMessage" +) + type RuntimeIncidentIngesterOnFinishedMessage struct { ReportTime time.Time `json:"reportTime"` SendTime time.Time `json:"sendTime"` diff --git a/pulsar/common/properties.go b/pulsar/common/properties.go index a1cfc30..669bfc4 100644 --- a/pulsar/common/properties.go +++ b/pulsar/common/properties.go @@ -16,4 +16,6 @@ const ( MsgPropAccount = "account" MsgPropCluster = "cluster" + + MsgPropMessageType = "messageType" )