Struct PartitionReplication 

pub struct PartitionReplication {
    pub partition_id: PartitionId,
    /* private fields */
}

Replication state for a single partition

Fields

partition_id: PartitionId

Partition identifier

Implementations

impl PartitionReplication

pub fn new( partition_id: PartitionId, local_node: NodeId, is_leader: bool, config: ReplicationConfig, ) -> Self

Create new partition replication state

pub async fn become_leader(&self, epoch: u64, replicas: Vec<NodeId>)

Become leader for this partition

pub fn become_follower(&self, epoch: u64)

Become follower for this partition

pub async fn record_appended(&self, offset: u64) -> Result<()>

Record appended locally (called by storage layer)

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

Handle replica fetch and update progress Returns true if ISR changed

pub async fn check_replica_health(&self) -> Vec<NodeId>

Check for lagging replicas and remove from ISR

pub async fn wait_for_acks(&self, offset: u64, acks: Acks) -> Result<()>

Wait for replication based on ack mode

pub fn high_watermark(&self) -> u64

Get current high watermark

pub fn log_end_offset(&self) -> u64

Get current log end offset

pub fn leader_epoch(&self) -> u64

Get current leader epoch

pub async fn get_isr(&self) -> HashSet<NodeId>

Get current ISR

pub async fn has_min_isr(&self) -> bool

Check if we have enough ISR for writes

pub fn cleanup_stale_pending_acks(&self, timeout: Duration) -> usize

Clean up stale pending acks that have exceeded the timeout

Sends Err(Timeout) to waiters before removing stale entries, so callers get a clear timeout error instead of a misleading ChannelClosed. This should be called periodically to prevent memory leaks from pending acks that were never completed (e.g., due to network partitions). Returns the number of cleaned up entries.

Trait Implementations

impl Debug for PartitionReplication

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

Formats the value using the given formatter.