pubsub

Documentation

Index

• type DingdingRobotEvent
• type EventGroupReduceEvent
• type EventType
• type MessageGroupPendingEvent
• type MessageGroupTriggeredEvent
• type Provider
  • func (s Provider) Aggregates() []infra.Provider
  • func (s Provider) Boot(infra.Resolver)
  • func (s Provider) Register(infra.Binder)
• type RuleChangedEvent
• type SystemUpDownEvent
• type UserChangedEvent

Types

type DingdingRobotEvent

type DingdingRobotEvent struct {
	DingDingRobot repository.DingdingRobot
	Type          EventType
	CreatedAt     time.Time
}

DingdingRobotEvent 钉钉机器人变更事件

type EventGroupReduceEvent

type EventGroupReduceEvent struct {
	GroupID     primitive.ObjectID
	KeepCount   int64
	DeleteCount int64
	CreatedAt   time.Time
}

EventGroupReduceEvent 事件组缩减事件

type EventType

type EventType string

EventType 事件类型

const (
	// EventTypeAdd 新增事件
	EventTypeAdd EventType = "added"
	// EventTypeUpdate 更新事件
	EventTypeUpdate EventType = "updated"
	// EventTypeDelete 删除事件
	EventTypeDelete EventType = "deleted"
)

type MessageGroupPendingEvent

type MessageGroupPendingEvent struct {
	Group     repository.EventGroup
	CreatedAt time.Time
}

MessageGroupPendingEvent 消息分组变更状态为 Pending 事件

type MessageGroupTriggeredEvent

type MessageGroupTriggeredEvent struct {
	Action    string
	Rule      repository.Rule
	Trigger   repository.Trigger
	Group     repository.EventGroup
	CreatedAt time.Time
}

MessageGroupTriggeredEvent 消息分组的 Trigger 触发事件

type Provider

type Provider struct{}

func (Provider) Aggregates

func (s Provider) Aggregates() []infra.Provider

func (Provider) Boot

func (s Provider) Boot(infra.Resolver)

func (Provider) Register

func (s Provider) Register(infra.Binder)

type RuleChangedEvent

type RuleChangedEvent struct {
	Rule      repository.Rule
	Type      EventType
	CreatedAt time.Time
}

RuleChangedEvent 规则变更事件

type SystemUpDownEvent

type SystemUpDownEvent struct {
	Up        bool
	CreatedAt time.Time
}

SystemUpDownEvent 系统启停事件

type UserChangedEvent

type UserChangedEvent struct {
	User      repository.User
	Type      EventType
	CreatedAt time.Time
}

UserChangedEvent 用户变更事件