events

type Dispatcher interface {
	// Dispatch provides all relevant listeners with an event to process.
	// It returns the same Event object it was passed after it is done invoking
	// Listeners. The Event may have been mutated by Listeners.
	// If an error or propagation stop was returned by one of the Listeners,
	// or if the context is canceled, the dispatch loop is terminated and
	// Dispatch returns that error, possibly wrapped with context data.
	Dispatch(context.Context, Event) (Event, error)

	// AddProviders sets the ListenerProviders for Events with a given Topic.
	// It returns the modified provider, making the call chainable.
	AddProviders(Topic, ...ListenerProvider) Dispatcher

	// Reset re-initializes the list of providers for the specified Topic values,
	// returning the dispatcher without any listener provider for those.
	Reset(topics ...Topic) Dispatcher
}

type Error string

type Event interface {
	// Topic returns an administrative label for the event.
	Topic() Topic

	// Data returns a generic payload.
	//
	// Event implementations should provide more strictly typed interfaces for
	// Listeners to use, allowing them to assert for the actual expected type
	// and use the typed getters accordingly.
	Data() interface{}

	Request() *http.Request
	Response() *http.Response
	Err() error

	// SetData is a setter for the data returned by Data.
	SetData(interface{}) Event
	// SetRequest is a setter for the event request, returning the event.
	SetRequest(r *http.Request) Event
	// SetResponse is a setter for the event response, returning the event.
	SetResponse(r *http.Response) Event
	// SetError is a setter for the error, returning the event.
	SetError(err error) Event
}

type EventBase struct {
	Error error
	// contains filtered or unexported fields
}

type Listener func(context.Context, Event) error

type ListenerProvider interface {
	Listeners(Event) []Listener
}

type ListenerProviderFunc func(e Event) []Listener

type Topic string