Struct PoolClusterAdmin 

pub struct PoolClusterAdmin { /* private fields */ }

ClusterAdmin backed by an Arc<ServerPool>.

Mutations stage into an internal Mutex<Vec<ClusterChange>>; cluster_commit applies every staged entry under the pool’s existing RwLocks and rebuilds the token continuum once on the way out so dispatch sees the new ring.

Implementations

impl PoolClusterAdmin

pub fn new(pool: Arc<ServerPool>) -> Self

Build a fresh admin handle wrapping pool.

pub fn pool(&self) -> &Arc<ServerPool>

Borrow the pool the handle was built over. Useful when a caller needs to consult the topology directly (e.g. the dispatcher) without going through the admin RPC.

Trait Implementations

impl ClusterAdmin for PoolClusterAdmin

fn list_peers(&self) -> Vec<PeerSnapshot>

Snapshot of every peer the gossip layer has seen.

fn cluster_join(&self, target: SocketAddr) -> Result<JoinPlan, ClusterError>

Stage a Add change for target and return the plan.

fn cluster_leave(&self, peer_idx: u32) -> Result<JoinPlan, ClusterError>

Stage a Remove change for peer_idx and return the plan.

fn cluster_plan_pending(&self) -> Vec<ClusterChange>

Snapshot of every staged-but-uncommitted change.

fn cluster_commit(&self) -> Result<(), ClusterError>

Apply every staged change and clear the staging list.

impl Debug for PoolClusterAdmin

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

Formats the value using the given formatter.