diff --git a/constants/event.go b/constants/event.go index e4ea62e..11dbf29 100644 --- a/constants/event.go +++ b/constants/event.go @@ -52,15 +52,13 @@ const ( const ( // EventStatusHappended define status for event record when event just happened, no data attached yet EventStatusHappended = iota - // EventStatusDataAttached define status for event record when event just happened, data attached already + // EventStatusDataAttached define status for event record when event data attached, ready to be sent EventStatusDataAttached - // EventStatusReported define status for event record when event reported to CIM, no matter it's successful or failed + // EventStatusReported define status for event record when event reported to downstream, no matter it's successful or failed EventStatusReported - // EventStatusConfirmed define status for event record when event confirmed by CIM, no matter it's successful or failed + // EventStatusConfirmed define status for event record when event confirmed by operator or CIM EventStatusConfirmed - // EventStatusPersisted define status for event record when event persisted in database, no matter it's successful or failed - EventStatusPersisted - // EventStatusClosed define status for event record when event closed, no matter it's successful or failed + // EventStatusClosed define status for event record when event closed due to condition recovery or manual close EventStatusClosed ) diff --git a/mq/event/event.go b/mq/event/event.go index 6740251..951242e 100644 --- a/mq/event/event.go +++ b/mq/event/event.go @@ -13,6 +13,8 @@ type EventRecord struct { Priority int `json:"priority"` // 事件状态 Status int `json:"status"` + // 是否已持久化到数据库,由 eventRT 消费并落库后置为 true + IsPersisted bool `json:"is_persisted"` // 可选模板参数 Category string `json:"category,omitempty"` // 毫秒级时间戳 (Unix epoch)