eventbus

Documentation

Index

• type EventBus
  • func NewEventBus() *EventBus
  • func (eb *EventBus) Publish(event interface{})
  • func (eb *EventBus) PublishMany(events []interface{})
  • func (eb *EventBus) Subscribe(eventType string, handler func(event interface{}))

Types

type EventBus

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

func NewEventBus

func NewEventBus() *EventBus

func (*EventBus) Publish

func (eb *EventBus) Publish(event interface{})

func (*EventBus) PublishMany

func (eb *EventBus) PublishMany(events []interface{})

func (*EventBus) Subscribe

func (eb *EventBus) Subscribe(eventType string, handler func(event interface{}))