ebus

Documentation

Index

• type DataEvent
• type EventBus
  • func Instance() *EventBus
  • func NewEventBus() *EventBus
  • func (eb *EventBus) Publish(topic string, data interface{})
  • func (eb *EventBus) Subscribe(topic string) *Subscription
• type Subscription

Types

type DataEvent

type DataEvent struct {
	Data  interface{}
	Topic string
}

DataEvent represents an event posted to a topic.

type EventBus

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

EventBus stores the information about subscribers interested for a particular topic.

func Instance

func Instance() *EventBus

Instance creates an single EventBus instance.

func NewEventBus

func NewEventBus() *EventBus

NewEventBus creates an EventBus instance.

func (*EventBus) Publish

func (eb *EventBus) Publish(topic string, data interface{})

Publish publishes data in the topic provided.

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe(topic string) *Subscription

Subscribe to the topic provided to receive data events.

type Subscription

type Subscription struct {
	Event       <-chan DataEvent
	Unsubscribe func()
}

Subscription represents a subscription to a topic.