Struct DefaultDistributedCluster 

pub struct DefaultDistributedCluster { /* private fields */ }

Default implementation of a distributed cluster

Implementations

impl DefaultDistributedCluster

pub fn new(coordinator: NodeId, configuration: ClusterConfiguration) -> Self

Create a new distributed cluster

Trait Implementations

impl Debug for DefaultDistributedCluster

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl DistributedCluster for DefaultDistributedCluster

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_id: NodeId) -> BoxFuture<'_, Result<()>>

Add a new node to the cluster

fn remove_node(&mut self, node_id: 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