Struct LeanWorkerStreamSummary 

pub struct LeanWorkerStreamSummary {
    pub total_rows: u64,
    pub per_stream_counts: BTreeMap<String, u64>,
    pub elapsed: Duration,
    pub metadata: Option<Value>,
}

Summary returned after a worker data-stream export completes.

Rows delivered to LeanWorkerDataSink are tentative until this summary is returned successfully. Downstream callers that need atomic commit should buffer rows in their sink and commit only after terminal success.

Fields

total_rows: u64

Total number of rows delivered to the parent before terminal success.

per_stream_counts: BTreeMap<String, u64>

Per-stream row counts assigned by lean-rs-worker.

elapsed: Duration

Elapsed time measured in the child for the streaming export.

metadata: Option<Value>

Optional downstream-defined terminal metadata.

Trait Implementations

impl Clone for LeanWorkerStreamSummary

fn clone(&self) -> LeanWorkerStreamSummary

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeanWorkerStreamSummary

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

Formats the value using the given formatter.

impl PartialEq for LeanWorkerStreamSummary

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for LeanWorkerStreamSummary

impl StructuralPartialEq for LeanWorkerStreamSummary