Package fanout provides an http.Handler that takes in one request and fans it out to N other requests, based on a list of Subscriptions.

Package multichannelfanout provides an http.Handler that takes in one request to a Knative Channel and fans it out to N other requests.

Package swappable provides an http.Handler that delegates all HTTP requests to an underlying multichannelfanout.Handler.

AppendToHistory appends a new host at the end of the list of hosts of the event history.

NewEventDispatcher creates a new event dispatcher that can dispatch events to HTTP destinations.

NewEventReceiver creates an event receiver passing new events to the receiverFunc.

ParseChannel converts the channel's hostname into a channel reference.

ResolveChannelFromHostHeader is a ReceiverOption for NewEventReceiver which enables the caller to overwrite the default behaviour defined by ParseChannel function.

EventHistory is the header containing all channel hosts traversed by the event.

ChannelReference references a Channel within the cluster by name and namespace.

DeliveryOptions are the delivery options supported by this dispatcher.

EventDispatcher dispatches events to a destination over HTTP.

EventReceiver starts a server to receive new events for the channel dispatcher.

UnknownChannelError represents the error when an event is received by a channel dispatcher for a channel that does not exist.

ReceiverFunc is the function to be called for handling the event.

ReceiverOptions provides functional options to EventReceiver function.

ResolveChannelFromHostFunc function enables EventReceiver to get the Channel Reference from incoming request HostHeader before calling receiverFunc.