Struct CommittedCheckpointIndex 

pub struct CommittedCheckpointIndex {

    pub version: u32,
    pub deployment_id: String,
    pub pipeline_identity: PipelineIdentity,
    pub epoch: u64,
    pub checkpoint_id: u64,
    pub scope: CheckpointScope,
    pub vnode_count: u16,
    pub assignment_fence: Option<CheckpointAssignmentFence>,
    pub reassignment_portable: bool,
    pub predecessor: Option<CommittedCheckpointRef>,
    pub participants: Vec<CommittedParticipantRef>,
    pub source_names: Vec<String>,
    pub source_offsets: BTreeMap<String, ConnectorCheckpoint>,
    pub channel_progress: Vec<ChannelProgress>,
    pub source_watermarks: BTreeMap<String, i64>,
    pub checkpoint_watermark: Option<i64>,
}

Canonical global recovery index selected by one Commit outcome.

Fields

version: u32

Exact index format.

deployment_id: String

Durable deployment incarnation owning the cut.

pipeline_identity: PipelineIdentity

Logical pipeline and state ABI identity.

epoch: u64

Terminal epoch.

checkpoint_id: u64

Exact checkpoint ID; equal to epoch.

scope: CheckpointScope

Recovery domain covered by the cut.

vnode_count: u16

Exact vnode domain used by every participant manifest.

assignment_fence: Option<CheckpointAssignmentFence>

Exact cluster assignment; absent in local mode.

reassignment_portable: bool

Whether every participant captured a cut portable across vnode reassignment.

predecessor: Option<CommittedCheckpointRef>

Direct prior committed index used for explicit, LIST-free retention traversal.

participants: Vec<CommittedParticipantRef>

Canonically sorted exact participant objects.

source_names: Vec<String>

Canonically sorted registered source names.

source_offsets: BTreeMap<String, ConnectorCheckpoint>

Complete merged connector source cut.

channel_progress: Vec<ChannelProgress>

Complete merged per-channel event-time progress.

source_watermarks: BTreeMap<String, i64>

Monotonic decision frontier retained for every source, including sources whose current physical input-channel inventory is empty.

checkpoint_watermark: Option<i64>

Safe event-time frontier at this cut.

Implementations

impl CommittedCheckpointIndex

pub fn validate(&self) -> Result<(), String>

Validate canonical shape and cross-field invariants.

Errors

Returns an error when the index is not a complete canonical checkpoint cut.

pub fn validate_predecessor_index( &self, predecessor: &CommittedCheckpointIndex, ) -> Result<(), String>

Validate metadata continuity for an explicitly loaded predecessor index.

Errors

Returns an error when either index is invalid or continuity is broken.

pub fn effective_source_watermarks( &self, ) -> Result<BTreeMap<String, i64>, String>

Return the source-keyed decision cuts represented by this index.

Version 3 encoded only physical channel progress, so its effective map is derived. Version 4 carries the cumulative map explicitly so an empty current inventory retains its cut.

Errors

Returns an error when channel progress contains an invalid watermark sentinel.

pub fn validate_participant_manifests( &self, manifests: &[(&CheckpointManifest, &[u8])], ) -> Result<(), String>

Verify exact participant manifest bytes and complete, exclusive vnode ownership.

Errors

Returns an error when the manifests do not exactly represent this committed cut.

pub fn encode_and_reference( &self, ) -> Result<(Vec<u8>, CommittedCheckpointRef), String>

Encode the canonical index and derive its exact content reference.

Errors

Returns an error when the index is invalid, cannot be encoded, or exceeds its bound.

Trait Implementations

impl Clone for CommittedCheckpointIndex

fn clone(&self) -> CommittedCheckpointIndex

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommittedCheckpointIndex

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CommittedCheckpointIndex

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for CommittedCheckpointIndex

impl PartialEq for CommittedCheckpointIndex

fn eq(&self, other: &CommittedCheckpointIndex) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for CommittedCheckpointIndex

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CommittedCheckpointIndex