events

Documentation

Index

• type Bus
  • func NewBus() *Bus
  • func (b *Bus) Destroy()
  • func (b *Bus) Off(listener Listener, topics ...string)
  • func (b *Bus) On(listener Listener, topics ...string)
  • func (b *Bus) Publish(topic string, data interface{})
• type Event
• type Listener

Types

type Bus

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

Bus represents an Event Bus.

func NewBus

func NewBus() *Bus

NewBus returns a new empty Event Bus.

func (*Bus) Destroy

func (b *Bus) Destroy()

Destroy destroys the Event Bus by unregistering and closing all listeners.

func (*Bus) Off

func (b *Bus) Off(listener Listener, topics ...string)

Off unregisters a listener from the specified topics on the Bus.

func (*Bus) On

func (b *Bus) On(listener Listener, topics ...string)

On registers a listener to the specified topics on the Bus.

func (*Bus) Publish

func (b *Bus) Publish(topic string, data interface{})

Publish publishes a message to the Bus.

type Event

type Event struct {
	Topic string
	Data  interface{}
}

Event represents an Event sent over a Bus.

type Listener

type Listener chan Event