Struct PipelineConfig 

pub struct PipelineConfig<Src: BlockMetadata, Dst: BlockMetadata> {

    pub policies: Vec<Arc<dyn OffloadPolicy<Src>>>,
    pub batch_config: BatchConfig,
    pub policy_timeout: Duration,
    pub auto_chain: bool,
    pub eval_input_capacity: usize,
    pub batch_input_capacity: usize,
    pub transfer_input_capacity: usize,
    pub sweep_interval: Duration,
    pub skip_transfers: bool,
    pub max_concurrent_transfers: usize,
    pub ordered_transfer_starts: bool,
    pub pending_tracker: Option<Arc<PendingTracker>>,
    pub max_concurrent_precondition_awaits: usize,
    /* private fields */
}

Configuration for a pipeline.

Fields

policies: Vec<Arc<dyn OffloadPolicy<Src>>>

Policies to evaluate (all must pass)

batch_config: BatchConfig

Batch configuration

policy_timeout: Duration

Timeout for policy evaluation (fail-fast)

auto_chain: bool

Whether arrivals from this pipeline auto-feed downstream

eval_input_capacity: usize

Channel capacity for evaluation input

batch_input_capacity: usize

Channel capacity for batch input

transfer_input_capacity: usize

Channel capacity for transfer input

sweep_interval: Duration

Sweep interval for cancellation task

skip_transfers: bool

Skip actual transfers (for testing)

max_concurrent_transfers: usize

Maximum number of concurrent transfer batches.

This controls how many batches can be transferred simultaneously. Setting this higher can improve throughput at the cost of memory. Default: 1 (sequential execution)

ordered_transfer_starts: bool

Whether transfer reservations must start in batch-input order.

This keeps concurrent transfers but removes executor scheduling from the order in which a synchronous worker observes their reservations.

pending_tracker: Option<Arc<PendingTracker>>

Pending tracker for duplicate prevention.

If provided, this tracker is used. If None, the pipeline creates its own. Share this tracker with presence-based policies to prevent duplicate transfers.

max_concurrent_precondition_awaits: usize

Maximum number of concurrent precondition awaits.

This controls how many batches can be awaiting their preconditions simultaneously. Allows multiple iterations to be in-flight without blocking the pipeline. Default: 8 (allows ~8 iterations in-flight concurrently)

Trait Implementations

impl<Src: Clone + BlockMetadata, Dst: Clone + BlockMetadata> Clone for PipelineConfig<Src, Dst>

fn clone(&self) -> PipelineConfig<Src, Dst>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Src: BlockMetadata, Dst: BlockMetadata> Default for PipelineConfig<Src, Dst>

fn default() -> Self

Returns the “default value” for a type.