Struct CheckpointManifest 

pub struct CheckpointManifest {

    pub version: u32,
    pub checkpoint_id: u64,
    pub epoch: u64,
    pub timestamp_ms: u64,
    pub participant_id: u64,
    pub source_offsets: HashMap<String, ConnectorCheckpoint>,
    pub source_names: Vec<String>,
    pub sink_names: Vec<String>,
    pub pipeline_identity: PipelineIdentity,
    pub deployment_id: String,
    pub partitioning_abi_version: u16,
    pub vnode_count: u16,
    pub assignment_fence: Option<CheckpointAssignmentFence>,
    pub reassignment_portable: bool,
    pub owned_vnodes: Vec<u16>,
    pub checkpoint_watermark: Option<i64>,
    pub channel_progress: Vec<ChannelProgress>,
    pub node_data: NodeDataObject,
    pub state_frames: Vec<StateFrame>,
    pub prepared_sinks: Vec<PreparedSinkDescriptor>,
    pub sink_artifact_intents: Vec<PreparedSinkArtifactIntent>,
    pub referenced_chunks: Vec<ReferencedStateChunk>,
    pub subscription_output: Option<NodeSubscriptionManifest>,
    pub view_log: Option<NodeDataObject>,
    pub view_logs: Vec<ViewLog>,
    pub referenced_view_logs: Vec<ReferencedStateChunk>,
}

A point-in-time snapshot of one participant’s pipeline state.

Fields

version: u32

Exact manifest format version.

checkpoint_id: u64

Unique, monotonically increasing checkpoint ID; must equal epoch.

epoch: u64

Persisted protocol epoch; must equal checkpoint_id.

timestamp_ms: u64

Creation time in milliseconds since the Unix epoch.

participant_id: u64

Node owning this manifest and its current data object.

source_offsets: HashMap<String, ConnectorCheckpoint>

Per-source connector offsets.

source_names: Vec<String>

Canonically sorted registered source names.

sink_names: Vec<String>

Canonically sorted registered sink names.

pipeline_identity: PipelineIdentity

Deterministic logical topology and state ABI identity.

deployment_id: String

Create-once checkpoint namespace incarnation.

partitioning_abi_version: u16

Durable key encoding, hashing, and key-group mapping contract.

vnode_count: u16

Virtual partition count.

assignment_fence: Option<CheckpointAssignmentFence>

Exact cluster assignment generation and participant fence; local manifests use None.

reassignment_portable: bool

Whether this cut can be restored under a different cluster vnode assignment.

Cluster manifests must carry an affirmative, capture-time proof. Local manifests cannot claim reassignment portability because they have no assignment-fenced recovery domain.

owned_vnodes: Vec<u16>

Canonically sorted vnodes whose state inventory this participant supplies.

checkpoint_watermark: Option<i64>

Derived checkpoint watermark retained with the exact cut.

channel_progress: Vec<ChannelProgress>

Canonically ordered per-channel watermarks and idle/uninitialized states.

node_data: NodeDataObject

The state data object written by this node for this checkpoint.

state_frames: Vec<StateFrame>

Canonically ordered complete logical state inventory.

prepared_sinks: Vec<PreparedSinkDescriptor>

Canonically ordered phase-one sink descriptor inventory.

sink_artifact_intents: Vec<PreparedSinkArtifactIntent>

Canonically ordered recovery intents captured before sink epoch begin.

referenced_chunks: Vec<ReferencedStateChunk>

Canonically ordered older objects retained by state_frames.

subscription_output: Option<NodeSubscriptionManifest>

Participant-local subscription output ranges and immutable segment references.

view_log: Option<NodeDataObject>

The view-log object this node wrote for this checkpoint, at the node_data chunk identity; None when no view appended rows.

view_logs: Vec<ViewLog>

Canonically ordered append-only view logs retained at this cut.

referenced_view_logs: Vec<ReferencedStateChunk>

Canonically ordered older view-log objects retained by view_logs.

Implementations

impl CheckpointManifest

pub fn new(checkpoint_id: u64, epoch: u64) -> Self

Create a prepared manifest with the common vnode topology.

pub fn new_with_key_group_count( checkpoint_id: u64, epoch: u64, key_group_count: KeyGroupCount, ) -> Self

Create a prepared manifest with an explicit vnode topology.

pub fn bind_participant(&mut self, participant_id: u64)

Bind the manifest and current data-object identity to one participant.

pub fn validate( &self, expected_key_group_count: KeyGroupCount, ) -> Vec<ManifestValidationError>

Validate the exact v11 recovery contract.

Trait Implementations

impl Clone for CheckpointManifest

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CheckpointManifest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CheckpointManifest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for CheckpointManifest

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for CheckpointManifest

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 CheckpointManifest