Struct SplitProgress 

#[non_exhaustive]
pub struct SplitProgress {
    pub watermark: i64,
    pub state: Vec<u8>,
    pub completed: bool,
}

One split’s durable progress, written through the fenced commit and handed to the next owner in CoordinationEvent::Gained.

The state payload is opaque to the framework and to backends — arbitrary bytes, no encoding constraint. The source owns its schema; keeping it opaque is what keeps connector types out of spate-core’s public API.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

watermark: i64

Committable watermark: one past the last acknowledged record, in the source’s own offset encoding. Backends enforce that it never decreases across a split’s committed history.

state: Vec<u8>

Source-defined opaque resume state.

completed: bool

Bounded jobs: this split is fully delivered and committed. Terminal — a backend never re-offers a completed split.

Implementations

impl SplitProgress

pub fn new(watermark: i64, state: Vec<u8>) -> SplitProgress

In-progress split state (completed: false).

pub fn completed(watermark: i64, state: Vec<u8>) -> SplitProgress

Terminal split state: fully delivered and committed.

Trait Implementations

impl Clone for SplitProgress

fn clone(&self) -> SplitProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SplitProgress

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

Formats the value using the given formatter.

impl Eq for SplitProgress

impl PartialEq for SplitProgress

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SplitProgress