eventbus

Documentation

Index

• Variables
• func DestroyEventBus()
• func InitEventBus(startBlockEventCount uint, dealEventRoutingCount uint8)
• type Event
• type EventBus
  • func GetBus() *EventBus
  • func (bus *EventBus) Publish(events ...interface{})
  • func (bus *EventBus) RegisterAllExistEvents(subscriber Subscriber) error
  • func (bus *EventBus) RegisterSubscriber(subscriber Subscriber, events ...interface{}) error
  • func (bus *EventBus) UnRegisterAllEvents(subscriber Subscriber) error
  • func (bus *EventBus) UnRegisterSubscriber(subscriber Subscriber, events ...interface{}) error
• type Subscriber

Variables

var (
	ErrParam = errors.New("没有传递必要的参数")
)

Functions

func DestroyEventBus

func DestroyEventBus()

func InitEventBus

func InitEventBus(startBlockEventCount uint, dealEventRoutingCount uint8)

Types

type Event

type Event struct {
	PublishTypeName string
	PublishEvent    interface{}
}

type EventBus

type EventBus struct {
	// contains filtered or unexported fields
}

func GetBus

func GetBus() *EventBus

func (*EventBus) Publish

func (bus *EventBus) Publish(events ...interface{})

func (*EventBus) RegisterAllExistEvents

func (bus *EventBus) RegisterAllExistEvents(subscriber Subscriber) error

func (*EventBus) RegisterSubscriber

func (bus *EventBus) RegisterSubscriber(subscriber Subscriber, events ...interface{}) error

func (*EventBus) UnRegisterAllEvents

func (bus *EventBus) UnRegisterAllEvents(subscriber Subscriber) error

func (*EventBus) UnRegisterSubscriber

func (bus *EventBus) UnRegisterSubscriber(subscriber Subscriber, events ...interface{}) error

type Subscriber

type Subscriber interface {
	OnEvent(event *Event)
}