Struct PartitionGuardSet 

pub struct PartitionGuardSet { /* private fields */ }

A set of partition guards managed by a single node.

Implementations

impl PartitionGuardSet

pub fn new(node_id: NodeId) -> Self

Create a new empty guard set for the given node.

pub fn insert(&mut self, partition_id: u32, epoch: u64)

Add a guard for a partition.

pub fn remove(&mut self, partition_id: u32) -> Option<PartitionGuard>

Remove a guard for a partition.

pub fn check(&self, partition_id: u32) -> Result<(), EpochError>

Check that a partition is still owned at the expected epoch.

Errors

Returns EpochError::NotTracked if the partition is not in the set, or EpochError::Fenced if the epoch has changed.

pub fn get(&self, partition_id: u32) -> Option<&PartitionGuard>

Get a guard by partition ID.

pub fn len(&self) -> usize

Get the number of tracked partitions.

pub fn is_empty(&self) -> bool

Returns true if no partitions are tracked.

pub fn iter(&self) -> impl Iterator<Item = (&u32, &PartitionGuard)>

Iterate over all guards.

pub fn update_epoch(&self, partition_id: u32, new_epoch: u64)

Update the cached epoch for a partition from Raft state.

Trait Implementations

impl Debug for PartitionGuardSet

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

Formats the value using the given formatter.