Crate rabble [−] [src]
Reexports
pub use errors::Result; |
Modules
| errors | |
| serialize |
Structs
| ClusterServer |
A struct that handles cluster membership connection and routing of messages to processes on other nodes. |
| 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. |
| Executor | |
| ExecutorMetrics | |
| ExecutorStatus | |
| 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 |
Enums
| ConnectionMsg |
Connection messages are returned from the callback functions for a Connection. |
| Metric | |
| Msg |
Traits
| ConnectionHandler |
Implement this for a specific connection handler |
| Process | |
| 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. |