Struct VnodeAssignmentSnapshot 

pub struct VnodeAssignmentSnapshot { /* private fields */ }

One immutable publication of vnode ownership and the source cursors that belong to the same assignment version.

Implementations

impl VnodeAssignmentSnapshot

pub const fn version(&self) -> u64

Monotonic assignment version for this publication.

pub fn owners(&self) -> &[NodeId]

Immutable vnode-owner vector for this publication.

pub fn owner_changed_version(&self, vnode: u32) -> Option<u64>

Version of the last ownership change for vnode.

pub const fn has_committed_handoff(&self) -> bool

Whether this publication carries a durable decided checkpoint cut.

pub fn source_handoff(&self, source: &str) -> Option<&SourceHandoffState>

Validated committed state for one source, without cloning its checkpoint maps.

pub fn committed_source_handoff(&self) -> Option<&CommittedSourceHandoff>

Complete committed source cut carried by this publication, if present.

pub const fn source_handoff_installed_version(&self) -> Option<u64>

Assignment version that installed the current handoff. Carry-only publications preserve the earlier version so runtimes do not restore the same recovery cut for an unrelated roster update.

pub fn source_handoff_attempt(&self) -> Option<CheckpointAttempt>

Exact checkpoint attempt supplying the committed handoff, if present.

pub fn source_handoff_assignment_version(&self) -> Option<u64>

Assignment version sealed by the committed handoff, if present.

pub fn source_handoff_cluster_watermark(&self) -> Option<CheckpointWatermark>

Explicit cluster event-time status at the committed cut, if present.

Trait Implementations

impl Clone for VnodeAssignmentSnapshot

fn clone(&self) -> VnodeAssignmentSnapshot

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.