bus

Documentation

Index

• type MessageBus
  • func (b *MessageBus) DeregisterHandler(key string)
  • func (b *MessageBus) Emit(topicName string, data interface{}, txID string) (event *bus.Event, err error)
  • func (b *MessageBus) Init()
  • func (b *MessageBus) ListHandlerKeys() []string
  • func (b *MessageBus) RegisterHandler(key, matcher string, handlerFunc func(e *bus.Event))
  • func (b *MessageBus) RegisterTopic(topicNames ...string)

Types

type MessageBus

type MessageBus struct{}

func (*MessageBus) DeregisterHandler

func (b *MessageBus) DeregisterHandler(key string)

func (*MessageBus) Emit

func (b *MessageBus) Emit(topicName string, data interface{}, txID string) (event *bus.Event, err error)

func (*MessageBus) Init

func (b *MessageBus) Init()

func (*MessageBus) ListHandlerKeys

func (b *MessageBus) ListHandlerKeys() []string

func (*MessageBus) RegisterHandler

func (b *MessageBus) RegisterHandler(key, matcher string, handlerFunc func(e *bus.Event))

func (*MessageBus) RegisterTopic

func (b *MessageBus) RegisterTopic(topicNames ...string)