Struct ApplyOpts 

pub struct ApplyOpts {
    pub max_in_flight: usize,
    pub batch_size: usize,
    pub batch_max_wait: Duration,
    pub timeout: Duration,
    pub failure_policy: FailurePolicy,
}

Options for crate::pipeline::run_change_feed, crate::pipeline::write_rows, and crate::pipeline::ApplyContext.

max_in_flight is the apply window size (default 1): concurrent transforms plus batches awaiting/in ordered sink. W=1 and W=16 share the same runtime — reads may overlap transforms and ordered writes; source watermark advance stays after sink success.

Fields

max_in_flight: usize

Maximum batches in the apply window (transforming + awaiting/in sink). Default: 1.

batch_size: usize

Accumulate this many changes before starting a transform batch. Default: 1000.

batch_max_wait: Duration

Flush a partial batch after this idle wait. Default: 500ms.

timeout: Duration

Per-batch transform timeout. Default: 60s.

failure_policy: FailurePolicy

Transform / sink failure handling. Default: FailurePolicy::Fail.

Implementations

impl ApplyOpts

pub fn identity() -> Self

Apply options for an identity (no-config) sync path.

Pins max_in_flight = 1 and batch_size = 1 so omit---transforms-config keeps per-event CDC cadence (no multi-change buffering, no overlapping transform window). Full-sync / ad-hoc helpers still go through the same crate::pipeline::ApplyContext path; there is no separate oneshot bypass.

pub fn with_max_in_flight(self, n: usize) -> Self

Builder: set in-flight window size (clamped to at least 1).

pub fn with_batch_size(self, n: usize) -> Self

Builder: set batch size (clamped to at least 1).

pub fn with_batch_max_wait(self, d: Duration) -> Self

Builder: set max wait before flushing a partial batch.

pub fn with_timeout(self, d: Duration) -> Self

Builder: set per-batch transform timeout.

pub fn with_failure_policy(self, policy: FailurePolicy) -> Self

Builder: set failure policy.

impl ApplyOpts

pub fn from_transforms_config(cfg: &TransformsConfig) -> Self

Derive apply options from [pipeline] (defaults when unset).

Trait Implementations

impl Clone for ApplyOpts

fn clone(&self) -> ApplyOpts

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ApplyOpts

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

Formats the value using the given formatter.

impl Default for ApplyOpts

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ApplyOpts

impl PartialEq for ApplyOpts

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ApplyOpts