newbus

Documentation

Index

• type Bus
  • func NewBus() (*Bus, error)
  • func (b *Bus) Dispatch(event string)
  • func (b *Bus) Publish(event string, msg message.Message) error
  • func (b *Bus) RegisterHandler(event string, handlerfunc HandlerFunc) error
• type DataChannel
• type EventInfo
• type HandlerFunc

Types

type Bus

type Bus struct {
	Events map[string]*EventInfo
	// contains filtered or unexported fields
}

Bus存储event消息channel及其handler Events map{eventName: eventInfo}

var UBus *Bus

func NewBus

func NewBus() (*Bus, error)

func (*Bus) Dispatch

func (b *Bus) Dispatch(event string)

func (*Bus) Publish

func (b *Bus) Publish(event string, msg message.Message) error

func (*Bus) RegisterHandler

func (b *Bus) RegisterHandler(event string, handlerfunc HandlerFunc) error

type DataChannel

type DataChannel chan message.Message

DataChannel 是一个能接收 message 的 channel

type EventInfo

type EventInfo struct {
	EventMsg    DataChannel
	HandlerFunc HandlerFunc
}

EventMsg save event message

type HandlerFunc

type HandlerFunc func(msg *message.Message) error

HandlerFunc defines a handler function interface.