Struct StreamReadings 

pub struct StreamReadings {
    pub stream_id: Uuid,
    pub source_key: String,
    pub readings: Vec<IngestReading>,
    pub audits: Vec<GroupAudit>,
    pub collection: bool,
    pub window: Option<SourceWindow>,
    pub annotations: Vec<AnnotationUpsert>,
}

Readings fetched for one stream, ready to ingest.

Fields

stream_id: Uuid

source_key: String

readings: Vec<IngestReading>

audits: Vec<GroupAudit>

Portal-precomputed mean/sd per replicate group, for server-side comparison.

collection: bool

Marks the readings as replicate collections; the API groups them per instant.

window: Option<SourceWindow>

The completeness claim, when this fetch read the source’s full content for the stream.

annotations: Vec<AnnotationUpsert>

Source-authored annotations riding this stream’s payload (e.g. the standard curve the source applied while producing a stored value). The driver registers them after the stream’s readings ingest; idempotent per (source_system, source_key).

Implementations

impl StreamReadings

pub fn new( stream_id: Uuid, source_key: String, readings: Vec<IngestReading>, ) -> Self

Plain single-series readings: no audits, not a collection, no completeness claim.

Trait Implementations

impl Debug for StreamReadings

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

Formats the value using the given formatter.