utils

Documentation

Index

• type EventListener
  • func (l *EventListener) Close()
  • func (l *EventListener) Wait(ctx context.Context) (eh.Event, error)
• type EventWaiter
  • func NewEventWaiter() *EventWaiter
  • func (w *EventWaiter) Listen(ctx context.Context, match func(eh.Event) bool) (*EventListener, error)
  • func (w *EventWaiter) Notify(ctx context.Context, event eh.Event) error

Types

type EventListener

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

EventListener receives events from an EventWaiter.

func (*EventListener) Close

func (l *EventListener) Close()

func (*EventListener) Wait

func (l *EventListener) Wait(ctx context.Context) (eh.Event, error)

type EventWaiter

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

EventWaiter waits for certain events to match a criteria.

func NewEventWaiter

func NewEventWaiter() *EventWaiter

NewEventWaiter returns a new EventWaiter.

func (*EventWaiter) Listen

func (w *EventWaiter) Listen(ctx context.Context, match func(eh.Event) bool) (*EventListener, error)

Listen waits unil the match function returns true for an event, or the context deadline expires. The match function can be used to filter or otherwise select interesting events by analysing the event data.

func (*EventWaiter) Notify

func (w *EventWaiter) Notify(ctx context.Context, event eh.Event) error

Notify implements the eventhorizon.EventObserver.Notify method which forwards events to the waiters so that they can match the events.