Crate rabble [−] [src]
Reexports
pub use errors::Result; |
Modules
errors |
Structs
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 |
ProtobufSerializer | |
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 |
Enums
ConnectionMsg |
Connection messages are returned from the callback functions for a Connection. |
Msg |
Traits
ConnectionHandler |
Implement this for a specific connection handler |
Process | |
Serialize |
This trait provides for reading framed messages from a |
ServiceHandler |
A service handler |
Functions
rouse |
Start a node in the rabble cluster and return it along with the handles to all threads started by rabble. |