Enum IngestProgress 

#[non_exhaustive]
pub enum IngestProgress {
    Started {
        total: usize,
    },
    DocumentSkipped {
        uri: String,
    },
    DocumentDone {
        uri: String,
        entities: usize,
        edges: usize,
    },
    DocumentFailed {
        uri: String,
        reason: String,
    },
    DocumentRejected {
        uri: String,
        reason: String,
    },
    Finished,
}

Incremental progress event emitted by crate::semantic::SemanticMemory::ingest_documents.

Sent on the mpsc::Sender<IngestProgress> channel passed to ingest_documents. The channel is advisory — a full or dropped receiver never fails the batch.

Wire contract

Events arrive in this order per batch: Started → (DocumentSkipped | DocumentDone | DocumentFailed | DocumentRejected)* → Finished

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Started

Emitted once before any document is processed.

Fields

total: usize

Total number of documents in the batch (after intra-batch dedup).

DocumentSkipped

A document was skipped because its (source_uri, content_hash) pair is already in the ingest ledger, or it was a duplicate within the same batch.

Fields

uri: String

Source locator of the skipped document.

DocumentDone

A document was successfully extracted and stored.

Fields

uri: String

Source locator of the processed document.

entities: usize

Number of graph entities upserted.

edges: usize

Number of graph edges inserted.

DocumentFailed

A document failed to extract or store; the batch continues.

Fields

uri: String

Source locator of the failed document.

reason: String

Human-readable failure reason.

DocumentRejected

A document was rejected by the post-extract validator (sanitizer).

Rejected documents write nothing to the graph or ledger. They are counted separately from failures in IngestReport so operators can distinguish sanitizer drops from extraction errors.

Fields

uri: String

Source locator of the rejected document.

reason: String

Rejection reason from the validator.

Finished

Emitted once after all documents have been processed.

Trait Implementations

impl Clone for IngestProgress

fn clone(&self) -> IngestProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngestProgress

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

Formats the value using the given formatter.