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 Eq for LeanWorkerStreamSummary

impl From<StreamSummary> for LeanWorkerStreamSummary

fn from(value: StreamSummary) -> Self

Converts to this type from the input type.

impl PartialEq for LeanWorkerStreamSummary

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for LeanWorkerStreamSummary