bus

Documentation

Index

• func Pub(e *event.Event) error
• func SetPublisher(p Publisher)
• func SetSubscriber(s Subscriber)
• func Sub(t event.Type, h EventHandler) error
• type EventHandler
• type Manager
• type Publisher
• type Subscriber

Functions

func Pub

func Pub(e *event.Event) error

Pub bus为全局对象

func SetPublisher

func SetPublisher(p Publisher)

SetPublisher 设置pub

func SetSubscriber

func SetSubscriber(s Subscriber)

SetSubscriber 设置sub

func Sub

func Sub(t event.Type, h EventHandler) error

Sub bus为全局对象

Types

type EventHandler

type EventHandler func(topic string, e *event.Event) error

EventHandler is used to process messages via a subscription of a topic.

type Manager

type Manager interface {
	Connect() error
	Disconnect() error
}

Manager 管理端

type Publisher

type Publisher interface {
	// 发送事件
	Pub(topic string, e *event.Event) error
}

Publisher 发送事件

type Subscriber

type Subscriber interface {
	Sub(topic string, h EventHandler) error
}

Subscriber 订阅事件