bus

Documentation

Index

• type Bus
  • func New(name string) Bus
• type Event
• type Listener

Types

type Bus

type Bus interface {
	// Publish an event to the bus
	Publish(Event)

	// Subscribe to all events, filter them to the ones containing *all* the keys in filter
	Subscribe(filter ...string) Listener
}

Bus provides a common channel to emit and listen for Events

func New

func New(name string) Bus

New initializes a new bus with the given name and returns it

type Event

type Event common.MapStr

Event sent to the bus

type Listener

type Listener interface {
	// Events channel
	Events() <-chan Event

	// Stop listening and removes itself from the bus
	Stop()
}

Listener retrieves Events from a Bus subscription until Stop is called