eventbus

Documentation

Index

• type Bus
  • func NewBus(c service.Container) (b *Bus, err error)
  • func (b *Bus) Emit(eventName string, data interface{})
  • func (b *Bus) On(eventName string, ch EventChannel)
• type Event
• type EventChannel
• type EventModel
  • func (m *EventModel) GetAll(tx *storage.Transaction, entries *[]Event) error

Types

type Bus

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

Bus that stores the events and dispatches them to the subscribers

func NewBus

func NewBus(c service.Container) (b *Bus, err error)

NewBus constructor

func (*Bus) Emit

func (b *Bus) Emit(eventName string, data interface{})

Emit publishes a event on all subscribing channels

func (*Bus) On

func (b *Bus) On(eventName string, ch EventChannel)

On subscribes a channel to a event on the bus

type Event

type Event struct {
	storage.Entity
	RawData interface{} `json:"-" gorm:"-"`
	Data    string      `json:"data"`
	Event   string      `json:"event"`
}

Event that triggers a state change

type EventChannel

type EventChannel chan Event

EventChannel channel that transports events

type EventModel

type EventModel struct {
	storage.Model
}

EventModel storage model

func (*EventModel) GetAll

func (m *EventModel) GetAll(tx *storage.Transaction, entries *[]Event) error

GetAll events