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.