Struct PartitionState 

pub struct PartitionState { /* private fields */ }

Shared partition state. Written by the replicator actor on the control channel, read lock-free by PartitionHandle and StateReplicatorHandle.

copy_lsn_map stores per-replica copy boundary LSNs. Written by run_build_replica_copy after snapshotting state, read by the actor at UpdateCatchUpConfiguration to replay only ops beyond the copy boundary (matching SF’s gap-free build approach).

Implementations

impl PartitionState

pub fn new() -> Self

pub fn read_status(&self) -> AccessStatus

pub fn write_status(&self) -> AccessStatus

pub fn current_progress(&self) -> Lsn

pub fn catch_up_capability(&self) -> Lsn

pub fn committed_lsn(&self) -> Lsn

pub fn set_read_status(&self, status: AccessStatus)

pub fn set_write_status(&self, status: AccessStatus)

pub fn set_current_progress(&self, lsn: Lsn)

pub fn set_catch_up_capability(&self, lsn: Lsn)

pub fn set_committed_lsn(&self, lsn: Lsn)

pub fn set_copy_lsn(&self, replica_id: ReplicaId, lsn: Lsn)

Record the copy snapshot LSN for a replica being built. Called by run_build_replica_copy after collecting state.

pub fn take_copy_lsn(&self, replica_id: &ReplicaId) -> Option<Lsn>

Take (read and remove) the copy snapshot LSN for a replica. Called by the actor at UpdateCatchUpConfiguration to determine the precise replay boundary.

Trait Implementations

impl Default for PartitionState

fn default() -> Self

Returns the “default value” for a type.