local

Documentation

Index

• Variables
• type EventBus
  • func NewEventBus(g *Group) *EventBus
  • func (b *EventBus) AddHandler(m eh.EventMatcher, h eh.EventHandler)
  • func (b *EventBus) AddObserver(m eh.EventMatcher, h eh.EventHandler)
  • func (b *EventBus) Close()
  • func (b *EventBus) Errors() <-chan eh.EventBusError
  • func (b *EventBus) PublishEvent(ctx context.Context, event eh.Event) error
  • func (b *EventBus) Wait()
• type Group
  • func NewGroup() *Group
  • func (g *Group) Close()

Variables

var DefaultQueueSize = 10

DefaultQueueSize is the default queue size per handler for publishing events.

Types

type EventBus

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

EventBus is a local event bus that delegates handling of published events to all matching registered handlers, in order of registration.

func NewEventBus

func NewEventBus(g *Group) *EventBus

NewEventBus creates a EventBus.

func (*EventBus) AddHandler

func (b *EventBus) AddHandler(m eh.EventMatcher, h eh.EventHandler)

AddHandler implements the AddHandler method of the eventhorizon.EventBus interface.

func (*EventBus) AddObserver

func (b *EventBus) AddObserver(m eh.EventMatcher, h eh.EventHandler)

AddObserver implements the AddObserver method of the eventhorizon.EventBus interface.

func (*EventBus) Close

func (b *EventBus) Close()

Close all the channels in the events bus group

func (*EventBus) Errors

func (b *EventBus) Errors() <-chan eh.EventBusError

Errors implements the Errors method of the eventhorizon.EventBus interface.

func (*EventBus) PublishEvent

func (b *EventBus) PublishEvent(ctx context.Context, event eh.Event) error

PublishEvent implements the PublishEvent method of the eventhorizon.EventBus interface.

func (*EventBus) Wait

func (b *EventBus) Wait()

Wait for all channels to close in the event bus group

type Group

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

Group is a publishing group shared by multiple event busses locally, if needed.

func NewGroup

func NewGroup() *Group

NewGroup creates a Group.

func (*Group) Close

func (g *Group) Close()

Close all the open channels