pubsub

Documentation

Index

• type DingdingRobotEvent
• type EventGroupReduceEvent
• type EventType
• type MessageGroupPendingEvent
• type MessageGroupTriggeredEvent
• type RuleChangedEvent
• type ServiceProvider
  • func (s ServiceProvider) Boot(app infra.Glacier)
  • func (s ServiceProvider) Register(app container.Container)
• 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 RuleChangedEvent

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

RuleChangedEvent 规则变更事件

type ServiceProvider

type ServiceProvider struct {
}

ServiceProvider 消息监听 Provider

func (ServiceProvider) Boot

func (s ServiceProvider) Boot(app infra.Glacier)

Boot 实现 ServiceProvider 接口

func (ServiceProvider) Register

func (s ServiceProvider) Register(app container.Container)

Register 实现 ServiceProvider 接口

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 用户变更事件