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 PubManager
• type Publisher
  • func P() Publisher
• type SubManager
• type Subscriber
  • func S() 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 PubManager

type PubManager interface {
	Manager
	Publisher
}

PubManager 带管理

type Publisher

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

Publisher 发送事件

func P

func P() Publisher

P todo

type SubManager

type SubManager interface {
	Manager
	Subscriber
}

SubManager 带管理

type Subscriber

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

Subscriber 订阅事件

func S

func S() Subscriber

S todo