eventbus

Documentation

Index

• func Close() error
• func NewEventbus() *defaultEventbus
• func Publish(ctx context.Context, topic string, message interface{}) error
• func SetEventbus(eb Eventbus)
• func Subscribe(ctx context.Context, topic string, handler EventHandler) error
• func Unsubscribe(ctx context.Context, topic string, handler EventHandler) error
• type Event
• type EventHandler
• type Eventbus
  • func GetEventbus() Eventbus

Functions

func Close

func Close() error

Close 关闭事件总线

func NewEventbus

func NewEventbus() *defaultEventbus

func Publish

func Publish(ctx context.Context, topic string, message interface{}) error

Publish 发布事件

func SetEventbus

func SetEventbus(eb Eventbus)

SetEventbus 设置事件总线

func Subscribe

func Subscribe(ctx context.Context, topic string, handler EventHandler) error

Subscribe 订阅事件

func Unsubscribe

func Unsubscribe(ctx context.Context, topic string, handler EventHandler) error

Unsubscribe 取消订阅

Types

type Event

type Event struct {
	ID        string      // 事件ID
	Topic     string      // 事件主题
	Payload   value.Value // 事件载荷
	Timestamp time.Time   // 事件时间
}

type EventHandler

type EventHandler func(event *Event)

type Eventbus

type Eventbus interface {
	// Close 关闭事件总线
	Close() error
	// Publish 发布事件
	Publish(ctx context.Context, topic string, message interface{}) error
	// Subscribe 订阅事件
	Subscribe(ctx context.Context, topic string, handler EventHandler) error
	// Unsubscribe 取消订阅
	Unsubscribe(ctx context.Context, topic string, handler EventHandler) error
}

func GetEventbus

func GetEventbus() Eventbus

GetEventbus 获取事件总线