bus

Documentation

Index

• func SetPublisher(p Publisher)
• func SetSubscriber(s Subscriber)
• type EventHandler
• type Manager
• type Publisher
  • func P() Publisher
• type Subscriber
  • func S() Subscriber

Functions

func SetPublisher

func SetPublisher(p Publisher)

SetPublisher 设置pub

func SetSubscriber

func SetSubscriber(s Subscriber)

SetSubscriber 设置sub

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 发送事件

func P

func P() Publisher

P bus为全局对象

type Subscriber

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

Subscriber 订阅事件

func S

func S() Subscriber

S bus为全局对象