eventbus

package

v0.6.0 Latest Latest Go to latest Published: Jan 3, 2021 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Bus that stores the events and dispatches them to the subscribers

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

NewBus constructor

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

Emit publishes a event on all subscribing channels

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

On subscribes a channel to a event on the bus

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 chan Event

EventChannel channel that transports events

type EventModel struct {
	storage.Model
}

EventModel storage model

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

GetAll events