Struct RunManifest 

pub struct RunManifest {

    pub manifest_version: u32,
    pub run_id: String,
    pub export_name: String,
    pub mode: String,
    pub started_at: String,
    pub finished_at: String,
    pub status: ManifestStatus,
    pub source: ManifestSource,
    pub destination: ManifestDestination,
    pub format: String,
    pub compression: String,
    pub schema_fingerprint: String,
    pub row_count: i64,
    pub part_count: u32,
    pub parts: Vec<ManifestPart>,
    pub column_checksums: Option<Vec<ColumnChecksum>>,
    pub checksum_key_column: Option<String>,
    pub row_hash: Option<RowHashContract>,
}

Public, stable JSON shape for the run manifest.

One manifest is written per run_id per export. See ADR-0012 M4 (Append-Only Per Run) for the resume-across-interruption story.

Fields

manifest_version: u32

run_id: String

export_name: String

mode: String

Which pipeline shape wrote this manifest — batch or cdc. Guards a prefix against silent cross-shape clobbering (finding #44: a CDC run overwrote a batch export’s manifest at a shared prefix, orphaning its parts from rivet validate). Defaults to batch for manifests written before this field existed.

started_at: String

finished_at: String

status: ManifestStatus

source: ManifestSource

destination: ManifestDestination

format: String

compression: String

schema_fingerprint: String

xxh3 fingerprint of the column schema; see crate::state::schema_fingerprint.

row_count: i64

part_count: u32

parts: Vec<ManifestPart>

column_checksums: Option<Vec<ColumnChecksum>>

Per-column value checksum over the whole export (Form B), keyed by column name — the per-column xxh3 XOR-combined over the run. rivet validate re-reads the parts and recomputes this to catch an Arrow→Parquet encode fault or post-write corruption — the step the in-process Form A check cannot see. Optional for back-compat: older manifests omit it (no MANIFEST_VERSION bump), newer readers tolerate its absence.

checksum_key_column: Option<String>

The column the Form B checksum is keyed to (xxh3(key ‖ value), the export’s cursor/key column) so validate re-keys identically. None ⇒ un-keyed (a full export with no cursor). See ColumnChecksum.

row_hash: Option<RowHashContract>

What this run’s _rivet_row_hash column covers, when meta_columns.row_hash was configured — the declared coverage plus the rendering’s identity.

The audit’s cheap path reads the persisted hash instead of the content columns, which is only sound if both sides hash the SAME thing. Probing that the column exists cannot establish that: a hash over (id, status) compared against a re-extraction of (id, status, amount) is a valid-looking column that silently attests a different text. The contract travels with the data so a reader can refuse instead of guessing. Optional for back-compat; older manifests omit it.

Implementations

impl RunManifest

pub fn committed_rows(&self) -> i64

Sum of rows across Committed parts. Used by M5 sanity checks and by --reconcile to compare against source COUNT(*).

pub fn committed_part_count(&self) -> usize

Number of Committed parts.

pub fn validate_self_consistency(&self) -> Result<(), ManifestInconsistency>

Verify that the recorded aggregates (row_count, part_count) match the actual Committed parts in parts. A mismatch is a writer bug; callers should refuse to act on the manifest until investigated.

Trait Implementations

impl Clone for RunManifest

fn clone(&self) -> RunManifest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunManifest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RunManifest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RunManifest

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RunManifest

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 RunManifest