local

Documentation

Index

• type EventPublisher
  • func NewEventPublisher() *EventPublisher
  • func (b *EventPublisher) AddObserver(observer eh.EventObserver)
  • func (b *EventPublisher) HandleEvent(ctx context.Context, event eh.Event) error

Types

type EventPublisher

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

EventPublisher is an event publisher that notifies registered EventHandlers of published events. It will use the SimpleEventHandlingStrategy by default.

func NewEventPublisher

func NewEventPublisher() *EventPublisher

NewEventPublisher creates a EventPublisher.

func (*EventPublisher) AddObserver

func (b *EventPublisher) AddObserver(observer eh.EventObserver)

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

func (*EventPublisher) HandleEvent

func (b *EventPublisher) HandleEvent(ctx context.Context, event eh.Event) error

HandleEvent implements the HandleEvent method of the eventhorizon.EventPublisher interface.