Struct SourceWindow 

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

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.

content_digest: Option<String>

Digest of the canonical payload, stamped by the driver before send. The server persists it on a cleanly-applied pass and echoes it on the stream list, so the next cycle can skip re-sending unchanged content. Opaque to the server; never computed server-side.

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.