internal

Documentation

Index

• type Controller
• type EventBus
  • func NewBus(logger *golog.Logger) EventBus
• type Handler
• type HandlerFunc
• type Hook
• type Publisher
• type Subscriber

Types

type Controller

type Controller interface {
	// 等待异步执行完成
	WaitAsync()
	// 设置同步订阅事务标记
	SetTransaction(topic string, tr bool)
	// 设置hook
	SetHook(topic string, hook Hook)
	// 关闭主题
	CloseTopic(topic string)
}

type EventBus

type EventBus interface {
	Publisher
	Subscriber
	Controller
}

func NewBus

func NewBus(logger *golog.Logger) EventBus

type Handler

type Handler interface {
	Handler(topic string, ctx *memstore.Store, args ...interface{}) error
}

Handler 因为会导致重复订阅,所以必须用interface的形式 type Handler = func(string, context.Context, ...interface{}) error

type HandlerFunc

type HandlerFunc = func(topic string, args ...interface{}) error

type Hook

type Hook interface {
	// 发布前回调
	Before(topic string, ctx *memstore.Store, args ...interface{}) error
	// 同步完成时回调
	AfterSync(topic string, ctx *memstore.Store, args ...interface{})
	// 全部完成时回调
	After(topic string, ctx *memstore.Store, args ...interface{})
	// 错误时回调
	Error(topic string, ctx *memstore.Store, err error, args ...interface{})
}

type Publisher

type Publisher interface {
	// 异步发布
	PublishAsync(topic string, args ...interface{})
	// 同步发布
	PublishSync(topic string, args ...interface{}) error
	// 同步发布, 不等待异步调用完成
	PublishSyncNoWait(topic string, args ...interface{}) error
}

type Subscriber

type Subscriber interface {
	// 同步订阅主题
	SubscribeSync(topic string, handler Handler) error
	// 异步订阅主题
	SubscribeAsync(topic string, handler Handler) error
	// 取消已订阅的主题
	UnSubscribe(topic string, handler Handler)
	// 取消所有已订阅的主题
	UnSubscribeAll(handler Handler)
}