Struct SourceWindow 

pub struct SourceWindow {
    pub from: DateTime<Utc>,
    pub to: DateTime<Utc>,
    pub source_rows_read: u64,
    pub dropped_times: Vec<DateTime<Utc>>,
}

A completeness claim over one stream: the readings sent alongside are the COMPLETE content of the source for this stream over [from, to), read from source_rows_read source rows. The server diffs stored content against the payload and converges (new / changed / withdrawn); without a window the request is a bare append, exactly the old semantics.

Fields

from: DateTime<Utc>

to: DateTime<Utc>

source_rows_read: u64

Source rows scanned to produce the payload. An empty payload over a window the store holds readings for is refused server-side, so a decode failure cannot read as a source deletion.

dropped_times: Vec<DateTime<Utc>>

Instants the backend saw but could not carry (cell decode failures). The server retains stored rows at these keys rather than withdrawing them.

Trait Implementations

impl Clone for SourceWindow

fn clone(&self) -> SourceWindow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceWindow

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SourceWindow

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SourceWindow

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.