Struct SourceLedger 

pub struct SourceLedger {
    pub sources: Vec<Source>,
}

Validated immutable Source table.

Fields

sources: Vec<Source>

Sources ordered by (recorded_at, source_uuid).

Implementations

impl SourceLedger

pub fn new(sources: Vec<Source>) -> Result<Self, KnowledgeError>

Validate, sort, and construct a Source table.

pub fn merge(&self, staged: &Self) -> Result<Self, KnowledgeError>

Merge staged rows into an existing ledger.

pub fn source_fingerprint( &self, source_uuid: Uuid, ) -> Result<[u8; 32], KnowledgeError>

Canonical semantic fingerprint over immutable Source content, excluding clock fields.

Excludes provenance_uuid and recorded_at_micros so that a retry with the same semantic content but a different clock value compares equal to the committed row.

pub fn batch(&self) -> Result<RecordBatch, KnowledgeError>

Encode the authoritative Arrow batch.

pub fn from_batches(batches: &[RecordBatch]) -> Result<Self, KnowledgeError>

Decode one or more Arrow batches.

Trait Implementations

impl Clone for SourceLedger

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 SourceLedger

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

Formats the value using the given formatter.

impl Default for SourceLedger

fn default() -> Self

Returns the “default value” for a type.

impl Eq for SourceLedger

impl PartialEq for SourceLedger

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceLedger