event

Documentation

Index

• type Bus
  • func NewBus() *Bus
  • func (b *Bus) Publish(topic string, data interface{})
  • func (b *Bus) Subscribe(topic string, fn func(data interface{}))

Types

type Bus

type Bus struct {
	TopicSubscribers map[string][]func(data interface{})
}

Bus provides the low-level transport layer for events.

func NewBus

func NewBus() *Bus

NewBus creates a Bus and returns its pointer.

func (*Bus) Publish

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

Publish sends data in context of a specific topic to all registered functions.

func (*Bus) Subscribe

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

Subscribe registers a function to a specific topic.