Struct RunStreamOptions 

pub struct RunStreamOptions {

    pub state_store: Option<Arc<dyn StateStore>>,
    pub state_key: Option<String>,
    pub pipeline_name: Option<String>,
    pub row: Option<String>,
    pub run_id: Option<String>,
    pub dlq: Option<DlqConfig>,
    pub quality: Option<Arc<CompiledQuality>>,
    pub adaptive: Option<AdaptiveBatchConfig>,
    pub cancel: Option<CancellationToken>,
    pub delivery: DeliveryMode,
    pub start_seq: u64,
    pub resilience: Option<ResiliencePolicy>,
    pub schema_drift: Option<SchemaDriftPolicy>,
}

Fields

state_store: Option<Arc<dyn StateStore>>

state_key: Option<String>

pipeline_name: Option<String>

row: Option<String>

run_id: Option<String>

dlq: Option<DlqConfig>

quality: Option<Arc<CompiledQuality>>

Available on crate feature quality only.

adaptive: Option<AdaptiveBatchConfig>

Adaptive batch-size controller config; None (or enabled = false) leaves the per-page write path unchanged.

cancel: Option<CancellationToken>

Cooperative cancellation. When set and cancelled mid-run, the streaming loop stops polling new pages, flushes the sinks (so a buffered sink like Parquet writes its footer / completes its upload rather than orphaning the file), and returns the partial result. Without this, a dropped run future loses everything written-but-unflushed (#146 H16).

delivery: DeliveryMode

Delivery guarantee. AtLeastOnce (default) leaves the write path unchanged. ExactlyOnce enables the resume/skip + atomic-token path.

start_seq: u64

Resume sequence read from the (unwrapped) exactly-once state value. Ignored unless delivery == ExactlyOnce. Defaults to 0.

resilience: Option<ResiliencePolicy>

Optional resilience policy (retry/backoff/circuit-breaker/poison).

schema_drift: Option<SchemaDriftPolicy>

Compiled schema-drift policy (issue #194). None → no drift handling.

Implementations

impl RunStreamOptions

pub fn new() -> RunStreamOptions

pub fn with_state( self, store: Arc<dyn StateStore>, key: impl Into<String>, ) -> RunStreamOptions

pub fn with_name(self, name: impl Into<String>) -> RunStreamOptions

pub fn with_row(self, row: impl Into<String>) -> RunStreamOptions

pub fn with_run_id(self, id: impl Into<String>) -> RunStreamOptions

pub fn with_dlq(self, dlq: DlqConfig) -> RunStreamOptions

pub fn with_cancel(self, cancel: CancellationToken) -> RunStreamOptions

Attach a cancellation token for cooperative, flush-completing cancel.

pub fn with_adaptive(self, cfg: AdaptiveBatchConfig) -> RunStreamOptions

Attach an adaptive batch-size controller config.

pub fn with_quality(self, quality: Arc<CompiledQuality>) -> RunStreamOptions

Available on crate feature quality only.

pub fn with_delivery(self, mode: DeliveryMode) -> RunStreamOptions

Set the delivery mode.

pub fn with_start_seq(self, seq: u64) -> RunStreamOptions

Set the resume sequence (exactly-once). Normally derived by Pipeline::run from the unwrapped state value.

pub fn with_resilience(self, policy: ResiliencePolicy) -> RunStreamOptions

Attach a resilience policy to the run.

pub fn with_schema_drift(self, policy: SchemaDriftPolicy) -> RunStreamOptions

Attach a compiled schema-drift policy. The pass runs per page after the quality pass and before the sink write.

Trait Implementations

impl Clone for RunStreamOptions

fn clone(&self) -> RunStreamOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for RunStreamOptions

fn default() -> RunStreamOptions

Returns the “default value” for a type.