async

Documentation

Index

• type Error
  • func (e Error) Error() string
• type EventHandler
  • func NewEventHandler(h eh.EventHandler) *EventHandler
  • func (h *EventHandler) Errors() <-chan Error
  • func (h *EventHandler) HandleEvent(ctx context.Context, event eh.Event) error

Types

type Error

type Error struct {
	Err   error
	Ctx   context.Context
	Event eh.Event
}

Error is an async error containing the error and the event.

func (Error) Error

func (e Error) Error() string

Error implements the Error method of the error interface.

type EventHandler

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

EventHandler is an async event handler middleware. It will run the event in a new go routine and report any errors to the error channel obtained by Errors().

func NewEventHandler

func NewEventHandler(h eh.EventHandler) *EventHandler

NewEventHandler creates a new EventHandler.

func (*EventHandler) Errors

func (h *EventHandler) Errors() <-chan Error

Errors returns an error channel where async handling errors are sent.

func (*EventHandler) HandleEvent

func (h *EventHandler) HandleEvent(ctx context.Context, event eh.Event) error

HandleEvent implements the HandleEvent method of the EventHandler interface.