Module flume

Memory transport implementation using flume

Structs

• AcceptBiFuture
  Future returned by FlumeServerEndpoint::accept
• FlumeConnection
  A flume based connection to a server endpoint.
• FlumeServerEndpoint
  A flume based server endpoint.
• OpenBiFuture
  Future returned by FlumeConnection::open
• RecvStream
  Stream for memory channels
• SendSink
  Sink for memory channels

Enums

• AcceptBiError
  AcceptBiError for mem channels.
• CreateChannelError
  CreateChannelError for mem channels.
• OpenBiError
  OpenBiError for mem channels.
• RecvError
  Error when receiving from a channel
• SendError
  SendError for mem channels.

Functions

• connection
  Create a flume server endpoint and a connected flume client channel.
• service_connection
  Create a flume server endpoint and a connected flume client channel for a specific service.