Trait DistributedCluster 

pub trait DistributedCluster: Send + Sync {
    // Required methods
    fn active_nodes(&self) -> BoxFuture<'_, Result<Vec<NodeId>>>;
    fn coordinator(&self) -> &NodeId;
    fn configuration(&self) -> &ClusterConfiguration;
    fn add_node(&mut self, node: NodeId) -> BoxFuture<'_, Result<()>>;
    fn remove_node(&mut self, node: NodeId) -> BoxFuture<'_, Result<()>>;
    fn rebalance_load(&mut self) -> BoxFuture<'_, Result<()>>;
    fn cluster_health(&self) -> BoxFuture<'_, Result<ClusterHealth>>;
    fn create_checkpoint(&self) -> BoxFuture<'_, Result<ClusterCheckpoint>>;
    fn restore_checkpoint(
        &mut self,
        checkpoint: ClusterCheckpoint,
    ) -> BoxFuture<'_, Result<()>>;
}

Distributed cluster management interface

Required Methods

fn active_nodes(&self) -> BoxFuture<'_, Result<Vec<NodeId>>>

Get all active nodes in the cluster

fn coordinator(&self) -> &NodeId

Get the cluster coordinator node

fn configuration(&self) -> &ClusterConfiguration

Get cluster configuration

fn add_node(&mut self, node: NodeId) -> BoxFuture<'_, Result<()>>

Add a new node to the cluster

fn remove_node(&mut self, node: NodeId) -> BoxFuture<'_, Result<()>>

Remove a node from the cluster

fn rebalance_load(&mut self) -> BoxFuture<'_, Result<()>>

Redistribute work across cluster nodes

fn cluster_health(&self) -> BoxFuture<'_, Result<ClusterHealth>>

Get cluster health status

fn create_checkpoint(&self) -> BoxFuture<'_, Result<ClusterCheckpoint>>

Create a checkpoint of cluster state

fn restore_checkpoint( &mut self, checkpoint: ClusterCheckpoint, ) -> BoxFuture<'_, Result<()>>

Restore from a checkpoint

Implementors

impl DistributedCluster for DefaultDistributedCluster