event_bus

Documentation

Index

• Constants
• type EventBus
  • func NewEventBus() EventBus
  • func (b EventBus) AppendListener(eventObj event.Event, listenerFunc interface{}, priority int) error
  • func (b EventBus) Dispatch(eventObj event.Event)
• type EventsRegistry
  • func NewRegistry() *EventsRegistry
  • func (r *EventsRegistry) GetEventByName(name string) (event.Event, error)
  • func (r *EventsRegistry) Register(name string, eventObj event.Event)

Constants

const (
	KernelEventApplicationLaunched    = "kernelEvent.ApplicationLaunched"
	KernelEventApplicationTermination = "kernelEvent.ApplicationTermination"
)

Types

type EventBus

type EventBus map[reflect.Type]listenersChain

func NewEventBus

func NewEventBus() EventBus

func (EventBus) AppendListener

func (b EventBus) AppendListener(eventObj event.Event, listenerFunc interface{}, priority int) error

eventObj - should be a pointer to the Event object listenerFunc - should be a function with one argument, that argument should be a pointer to the Event object priority - priority of this listener in listeners chain

func (EventBus) Dispatch

func (b EventBus) Dispatch(eventObj event.Event)

type EventsRegistry

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

func NewRegistry

func NewRegistry() *EventsRegistry

func (*EventsRegistry) GetEventByName

func (r *EventsRegistry) GetEventByName(name string) (event.Event, error)

func (*EventsRegistry) Register

func (r *EventsRegistry) Register(name string, eventObj event.Event)