behaviorx

type Action struct {
	Topic     string                                                              `json:"name"`    // 用于标记Topic的名称
	Deliver   map[string]interface{}                                              `json:"deliver"` // 用于传递消息的内容
	Assembler func(msg *messagex.Message) (map[string]interface{}, *errors.Error) // 用于组装消息内容
}

type Behavior struct {
	SubID  uint64    // 标记订阅的ID
	Name   string    `json:"name"` // 用于标记行为的名称
	First  *Behavior // 用于标记链路的第一个行为
	Action Action    `json:"action"` // 用于标记行为的动作
	Result Result    `json:"result"` // 用于标记行为的结果
	Next   *Behavior // 用于标记链路的下一个行为

}

type Result struct {
	Topic     string                                            `json:"name"`    // 用于标记Topic的名称
	Filters   map[string]interface{}                            `json:"filters"` // 用于过滤消息的内容
	Validator func(msg *messagex.Message) (bool, *errors.Error) // 用于校验消息内容
}