local

Documentation

Index

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

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) PublishEvent

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

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

func (*EventPublisher) SetHandlingStrategy

func (b *EventPublisher) SetHandlingStrategy(strategy eh.EventHandlingStrategy)

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