Crate rabble [−] [src]

Reexports

pub use errors::Result;

ClusterStatus
CorrelationId	Match requests through the system with their handlers
Envelope	Envelopes are routable to processes on all nodes and threads running on the same node as this process.
ExecutorStatus
MsgpackSerializer
Node	A Node represents a way for services to interact with rabble internals.
NodeId
Pid	A globally unique process id
Service	A system service that operates on a single thread. A service is registered via its pid with the executor and can send and receive messages to processes as well as other services.
TcpServerHandler	A service handler for an async TCP server
ThreadHandler

ConnectionMsg	Connection messages are returned from the callback functions for a Connection.
Msg

ConnectionHandler	Implement this for a specific connection handler
Process
Serialize	This trait provides for reading framed messages from a `Read` type, decoding them and returning them. It buffers incomplete messages. Reading of only a single message of a time is to allow for strategies that prevent starvation of other readers.
ServiceHandler	A service handler

Start a node in the rabble cluster and return it along with the handles to all threads started by rabble.