NewChannelEdge returns a new edge that uses channels as the underlying transport.

NewConsumerWithReceiver creates a new consumer for the edge e and receiver r.

NewGroupedConsumer creates a new grouped consumer for edge e and grouped receiver r.

NewReceiverFromForwardReceiver creates a new receiver from the provided list of edges and forward receiver.

NewReceiverFromForwardReceiverWithStats creates a new receiver from the provided list of stats edges and forward receiver.

NewStatsEdge creates an edge that tracks statistics about the message passing through the edge.

NewTimedForwardReceiver creates a forward receiver which times the time spent in r.

ErrAborted is returned from the Edge interface when operations are performed on the edge after it has been aborted.

BatchBuffer buffers batch messages into a BufferedBatchMessage.

GroupInfo identifies and contians information about a specific group.

GroupStats represents the statistics for a specific group.

BarrierMessage indicates that no data older than the barrier time will arrive.

BatchPointMessage is a single point in a batch of data.

BeginBatchMessage marks the beginning of a batch of points.

BufferedBatchMessage is a message containing all data for a single batch.

Consumer reads messages off an edge and passes them to a receiver.

Edge represents the connection between two nodes that communicate via messages.

EndBatchMessage indicates that all points for a batch have arrived.

ForwardBufferedReceiver handles messages as they arrive and can return a message to be forwarded to output edges.

ForwardReceiver handles messages as they arrive and can return a message to be forwarded to output edges.

GroupedConsumer reads messages off an edge and passes them by group to receivers created from a grouped receiver.

GroupedReceiver creates and deletes receivers as groups are created and deleted.

Message represents data to be passed along an edge.

PointMessage is a single point.

PointMeta is the common read interfaces of point and batch messages.

Receiver handles messages as they arrive via a consumer.

StatsEdge is an edge that tracks various statistics about message passing through the edge.