bus

Documentation

Index

• type Bus
  • func New() *Bus
  • func (bus *Bus) Publish(topic string, ev Event)
  • func (bus *Bus) PublishArgs(topic string, args ...interface{})
  • func (bus *Bus) Start() error
  • func (bus *Bus) Stop()
  • func (bus *Bus) Subscribe(topic string, ch interface{}) error
  • func (bus *Bus) SubscribeAsync(topic string, fn interface{}, transactional bool) error
  • func (bus *Bus) SubscribeEventChan(topic string, ch EventChan) error
  • func (bus *Bus) SubscribeOnce(topic string, fn interface{}) error
  • func (bus *Bus) SubscribeOnceAsync(topic string, fn interface{}) error
  • func (bus *Bus) UnSubscribe(topic string, ch interface{})
  • func (bus *Bus) Wait()
• type Event
• type EventChan
• type Publisher
• type Subscriber

Types

type Bus

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

func New

func New() *Bus

func (*Bus) Publish

func (bus *Bus) Publish(topic string, ev Event)

func (*Bus) PublishArgs

func (bus *Bus) PublishArgs(topic string, args ...interface{})

func (*Bus) Start

func (bus *Bus) Start() error

func (*Bus) Stop

func (bus *Bus) Stop()

func (*Bus) Subscribe

func (bus *Bus) Subscribe(topic string, ch interface{}) error

func (*Bus) SubscribeAsync

func (bus *Bus) SubscribeAsync(topic string, fn interface{}, transactional bool) error

func (*Bus) SubscribeEventChan

func (bus *Bus) SubscribeEventChan(topic string, ch EventChan) error

func (*Bus) SubscribeOnce

func (bus *Bus) SubscribeOnce(topic string, fn interface{}) error

SubscribeOnce subscribes to a topic once. Handler will be removed after executing. Returns error if `fn` is not a function.

func (*Bus) SubscribeOnceAsync

func (bus *Bus) SubscribeOnceAsync(topic string, fn interface{}) error

SubscribeOnceAsync subscribes to a topic once with an asynchronous callback Async determines whether subsequent Publish should wait for callback return Handler will be removed after executing. Returns error if `fn` is not a function.

func (*Bus) UnSubscribe

func (bus *Bus) UnSubscribe(topic string, ch interface{})

func (*Bus) Wait

func (bus *Bus) Wait()

type Event

type Event struct {
	Cmd  string
	Data interface{}
}

type EventChan

type EventChan chan Event

type Publisher

type Publisher interface {
	Publish(topic string, ev Event)
	PublishArgs(topic string, args ...interface{})
}

type Subscriber

type Subscriber interface {
	SubscribeEventChan(topic string, ch EventChan) error
	Subscribe(topic string, ch interface{}) error
	SubscribeAsync(topic string, ch interface{}, transactional bool) error
	SubscribeOnce(topic string, ch interface{}) error
	SubscribeOnceAsync(topic string, ch interface{}) error
	UnSubscribe(topic string, ch interface{})
}

Subscriber ch is func or chan.(EventChan)