tracing

Documentation

Index

• type EventBus
  • func NewEventBus(eventBus eh.EventBus) *EventBus
  • func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error
  • func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error

Types

type EventBus

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

EventBus is an event bus wrapper that adds tracing.

func NewEventBus

func NewEventBus(eventBus eh.EventBus) *EventBus

NewEventBus creates a EventBus.

func (*EventBus) AddHandler

func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error

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

func (*EventBus) HandleEvent

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

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