Struct PipelineConfig 

pub struct PipelineConfig {
    pub max_batch_size: usize,
    pub execution_timeout: Duration,
    pub use_transaction: bool,
    pub rollback_on_error: bool,
    pub max_depth: usize,
    pub collect_stats: bool,
}

Configuration for pipeline execution.

Fields

max_batch_size: usize

Maximum queries per pipeline batch.

execution_timeout: Duration

Timeout for entire pipeline execution.

use_transaction: bool

Whether to wrap pipeline in a transaction.

rollback_on_error: bool

Whether to rollback on any error.

max_depth: usize

Maximum pipeline depth (pending queries).

collect_stats: bool

Whether to collect execution statistics.

Implementations

impl PipelineConfig

pub fn for_bulk_inserts() -> Self

Create config optimized for bulk inserts.

pub fn for_bulk_updates() -> Self

Create config optimized for bulk updates.

pub fn for_mixed_operations() -> Self

Create config optimized for mixed operations.

pub fn with_max_batch_size(self, size: usize) -> Self

Set maximum batch size.

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

Set execution timeout.

pub fn with_transaction(self, use_tx: bool) -> Self

Set whether to use transaction.

Trait Implementations

impl Clone for PipelineConfig

fn clone(&self) -> PipelineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineConfig

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

Formats the value using the given formatter.

impl Default for PipelineConfig

fn default() -> Self

Returns the “default value” for a type.