Struct ReplicationManager 

pub struct ReplicationManager { /* private fields */ }

Manages replication across all partitions

Implementations

impl ReplicationManager

pub fn new(local_node: NodeId, config: ReplicationConfig) -> Self

Create new replication manager

pub fn set_raft_node(&mut self, raft_node: Arc<RwLock<RaftNode>>)

Set Raft node for ISR propagation

pub fn get_or_create( &self, partition_id: PartitionId, is_leader: bool, ) -> Arc<PartitionReplication>

Get or create partition replication state

pub fn get( &self, partition_id: &PartitionId, ) -> Option<Arc<PartitionReplication>>

Get partition replication state

pub fn remove( &self, partition_id: &PartitionId, ) -> Option<Arc<PartitionReplication>>

Remove partition replication state

pub fn leading_partitions(&self) -> Vec<PartitionId>

Get all partitions we’re leading

pub async fn handle_replica_fetch( &self, partition_id: &PartitionId, replica_id: &NodeId, fetch_offset: u64, ) -> Result<()>

Handle replica fetch and propagate ISR changes if needed

pub async fn run_health_checks(&self)

Run periodic health checks