事件类型

Author: yumaojun03

bus/event/event.go

@@ -15,18 +15,23 @@ import (
 // NewEvent 实例
 func NewEvent() *Event {
 	return &Event{
-		Header: Header{
-			ID:    xid.New().String(),
-			Time:  ftime.Now(),
-			Label: make(map[string]string),
-		},
+		ID:    xid.New().String(),
+		Time:  ftime.Now(),
+		Label: make(map[string]string),
 	}
 }
 
 // Event 事件数据结构
 type Event struct {
-	Header
-	Body
+	ID     string            `bson:"_id" json:"id"`        // 事件ID
+	Time   ftime.Time        `bson:"time" json:"time"`     // 事件发生时间(毫秒)
+	Source string            `bson:"source" json:"source"` // 事件来源, 比如cmdb
+	Level  Level             `bson:"level" json:"level"`   // 事件等级
+	Label  map[string]string `bson:"label" json:"label"`   // 标签
+	Meta   Meta              `bson:"meta" json:"meta"`     // 事件的元数据
+	Type   Type              `bson:"type" json:"type"`     // 事件类型
+	Body   interface{}       `bson:"body" json:"body"`     // 事件数据
+
 	ctx context.Context
 }
 
@@ -40,24 +45,23 @@ func (e *Event) Context() context.Context {
 	return e.ctx
 }
 
-// Header 事件元数据
-type Header struct {
-	ID     string            `bson:"_id" json:"id,omitempty"`        // 事件ID
-	Time   ftime.Time        `bson:"time" json:"time,omitempty"`     // 事件发生时间(毫秒)
-	Source string            `bson:"source" json:"source,omitempty"` // 事件来源, 比如cmdb
-	Level  Level             `bson:"level" json:"level,omitempty"`   // 事件等级
-	Label  map[string]string `bson:"label" json:"label,omitempty"`   // 标签
-	Meta   Meta              `bson:"meta" json:"meta,omitempty"`     // 事件的元数据
+// OperateEvent 事件具体数据
+type OperateEvent struct {
+	ResourceType string      `bson:"resource_type" json:"resource_type"` // 资源类型,
+	ResourceUUID string      `bson:"resource_uuid" json:"resource_uuid"` // 资源UUID
+	ResourceName string      `bson:"resource_name" json:"resource_name"` // 资源名称
+	Action       string      `bson:"action" json:"action"`               // 操作
+	Data         interface{} `bson:"data" json:"data,omitempty"`         // 事件数据
 }
 
-// Body 事件具体数据
-type Body struct {
+// AlertEvent 事件具体数据
+type AlertEvent struct {
 	Reason       string      `bson:"reason" json:"reason,omitempty"`     // 触发原因, 比如 创建/删除/绑定/告警/恢复
 	Message      string      `bson:"message" json:"message,omitempty"`   // 事件消息,
 	ResourceType string      `bson:"resource_type" json:"resource_type"` // 资源类型,
 	ResourceUUID string      `bson:"resource_uuid" json:"resource_uuid"` // 资源UUID
 	ResourceName string      `bson:"resource_name" json:"resource_name"` // 资源名称
-	Data         interface{} `bson:"data" json:"data,omitempty"`         // 事件具体数据
+	Data         interface{} `bson:"data" json:"data,omitempty"`         // 事件数据
 }
 
 // Meta todo

bus/event/type.go

@@ -0,0 +1,11 @@
+package event
+
+const (
+	// OperateEventType (operate_event) 资源操作事件
+	OperateEventType Type = iota
+	// AlertEventType (alert) 告警事件
+	AlertEventType
+)
+
+// Type 事件类型
+type Type uint

http/response/event.go

@@ -17,12 +17,7 @@ type ResourceEvent interface {
 
 func newEvent(re ResourceEvent) *event.Event {
 	e := event.NewEvent()
-	e.ResourceType = re.ResourceType()
-	e.ResourceUUID = re.ResourceUUID()
-	e.ResourceName = re.ResourceName()
 	e.Label["domain"] = re.ResourceDomain()
 	e.Label["namespace"] = re.ResourceNamespace()
-	e.Reason = re.ResourceAction()
-	e.Data = re.ResourceData()
 	return e
 }