Expand description
Memory transport implementation using flume
Structs§
- Future returned by FlumeListener::accept
- A flume based connector.
- A flume based listener.
- Future returned by FlumeConnector::open
- Stream for memory channels
- Sink for memory channels
Enums§
- AcceptError for mem channels.
- CreateChannelError for mem channels.
- OpenError for mem channels.
- Error when receiving from a channel
- SendError for mem channels.
Functions§
- Create a flume listener and a connected flume connector.