Struct PipelineSection 

pub struct PipelineSection {
    pub failure_policy: Option<FailurePolicy>,
    pub batch_size: Option<usize>,
    pub batch_max_wait: Option<Duration>,
    pub timeout: Option<Duration>,
    pub max_in_flight: Option<usize>,
}

Pipeline-wide apply-window options ([pipeline] in TOML).

These are not SurrealDB sink settings — they control how surreal-sync batches source events and overlaps transform work before ordered sink apply.

Fields

failure_policy: Option<FailurePolicy>

Override for ApplyOpts::failure_policy when set.

batch_size: Option<usize>

Override for ApplyOpts::batch_size when set.

batch_max_wait: Option<Duration>

Override for ApplyOpts::batch_max_wait when set.

timeout: Option<Duration>

Outer whole-pipeline transform timeout (covers all stages + retries).

max_in_flight: Option<usize>

Override for ApplyOpts::max_in_flight when set.

Trait Implementations

impl Clone for PipelineSection

fn clone(&self) -> PipelineSection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineSection

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

Formats the value using the given formatter.

impl Default for PipelineSection

fn default() -> PipelineSection

Returns the “default value” for a type.

impl Eq for PipelineSection

impl PartialEq for PipelineSection

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PipelineSection