msgbus

type Event ¶

type Event struct {
	Name string
	Data string // XXX interface{}? serialized data?
}

Event struct is used in two places:

1. Subscribing: an event's name is used as the underlying topic in EventBus
2. Publishing: an even't name is needed for the topic to publish to, and the event data is what get's published on the EventBus under that topic

func NewEvent(name string, data string) *Event

type MsgBus ¶

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

func NewMsgBus() *MsgBus

func (m *MsgBus) Publish(event *Event)

func (m *MsgBus) Subscribe(eventName string, fn interface{})

func (m *MsgBus) Topics() []string

type Topics ¶

type Topics struct {
	sync.RWMutex
	// contains filtered or unexported fields
}