Struct rabble::ClusterServer

pub struct ClusterServer<T> { /* fields omitted */ }

A struct that handles cluster membership connection and routing of messages to processes on other nodes.

Methods

impl<'de, T: Serialize + Deserialize<'de> + Debug + Clone> ClusterServer<T>

fn new(
    node: NodeId,
    rx: Receiver<ClusterMsg<T>>,
    executor_tx: Sender<ExecutorMsg<T>>,
    registrar: Registrar,
    logger: Logger
) -> ClusterServer<T>

fn run(self)