Struct ReplicasManager 

pub struct ReplicasManager { /* private fields */ }

Replicas manager

Manages broker replicas and sync state sets across the cluster. Provides functionality for:

• Replica registration and tracking
• ISR (In-Sync Replicas) management
• Master election and failover

Implementations

impl ReplicasManager

pub fn new(config: Arc<ControllerConfig>) -> Self

Create a new replicas manager

pub async fn start(&self) -> Result<()>

Start the replicas manager

pub async fn shutdown(&self) -> Result<()>

Shutdown the replicas manager

pub async fn register_replica(&self, replica: BrokerReplicaInfo) -> Result<()>

Register a replica

pub async fn unregister_replica( &self, broker_name: &str, broker_id: u64, ) -> Result<()>

Unregister a replica

pub async fn get_master(&self, broker_name: &str) -> Option<BrokerReplicaInfo>

Get the master replica for a broker set

pub async fn get_replicas(&self, broker_name: &str) -> Vec<BrokerReplicaInfo>

Get all replicas for a broker set

pub async fn get_replica( &self, broker_name: &str, broker_id: u64, ) -> Option<BrokerReplicaInfo>

Get a specific replica

pub async fn get_sync_state_set( &self, broker_name: &str, ) -> Option<SyncStateSet>

Get sync state set for a broker set

pub async fn add_to_sync_state_set( &self, broker_name: &str, broker_id: u64, ) -> Result<()>

Add a broker to the sync state set

pub async fn remove_from_sync_state_set( &self, broker_name: &str, broker_id: u64, ) -> Result<()>

Remove a broker from the sync state set

pub async fn update_sync_state_set( &self, broker_name: &str, new_sync_state_set: Vec<u64>, ) -> Result<()>

Update sync state set

pub async fn elect_master( &self, broker_name: &str, ) -> Result<Option<BrokerReplicaInfo>>

Elect a new master for a broker set

This is typically called when the current master fails. A new master is elected from the in-sync replicas.

pub async fn list_broker_sets(&self) -> Vec<String>

List all broker sets

pub async fn get_stats(&self) -> HashMap<String, usize>

Get statistics