Struct InputStreamState 

pub struct InputStreamState {
    pub lease: StreamLease,
    pub target: String,
    pub columns: Vec<String>,
    pub committed_rid: u64,
    pub row_count: u64,
    pub chunk_count: u64,
    pub snapshot_lsn: u64,
}

Per-stream state for an in-flight input stream. Lives in the session loop’s InputStreamRegistry and is mutated synchronously as each StreamChunk is committed.

Fields

lease: StreamLease

target: String

columns: Vec<String>

committed_rid: u64

CDC LSN at the last successful per-chunk commit; the start of the committed RID range is the lease’s snapshot_lsn.

row_count: u64

chunk_count: u64

snapshot_lsn: u64

Implementations

impl InputStreamState

pub fn new( lease: StreamLease, target: String, columns: Vec<String>, ) -> InputStreamState

pub fn commit_chunk( &mut self, runtime: &RedDBRuntime, rows: &[Value], ) -> Result<(), (String, String)>

Commit one chunk of rows as a single atomic multi-row INSERT. On success the rows are durable and committed_rid advances to the post-commit CDC LSN. On failure nothing in this chunk commits — committed_rid (and therefore recoverable_rid) stays at the last good commit, so chunks 1..N-1 remain durable (AC #3).

Trait Implementations

impl Debug for InputStreamState

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

Formats the value using the given formatter.