Struct PipelineConfig 

pub struct PipelineConfig {
    pub pipeline: PipelineSection,
    pub stages: StagesConfig,
    pub resilience: ResilienceConfig,
    pub rate_limits: RateLimitConfig,
    pub deduplication: DeduplicationConfig,
    pub observability: ObservabilityConfig,
    pub channel_sizes: Option<ChannelSizes>,
    pub workers: WorkersConfig,
}

Root configuration for a pipeline instance.

Deserialized from a TOML file and validated before use. Every field has either a required value or a documented default.

Example

[pipeline]
name = "production"
version = "1.0"

[stages.inference]
worker = "open_ai"
model = "gpt-4"

Panics

This type never panics during construction or access.

Fields

pipeline: PipelineSection

Pipeline identity and version metadata.

stages: StagesConfig

Per-stage configuration for the five pipeline stages.

resilience: ResilienceConfig

Resilience settings: retries, circuit breaker, backpressure.

rate_limits: RateLimitConfig

Rate limiting settings to control request throughput.

deduplication: DeduplicationConfig

Deduplication settings for request coalescing.

observability: ObservabilityConfig

Observability: logging, metrics, tracing.

channel_sizes: Option<ChannelSizes>

Optional per-channel capacity overrides. When absent, each stage uses its compiled-in default (512 / 512 / 1024 / 512 / 256).

workers: WorkersConfig

Optional per-worker configuration overrides.

Allows setting model, API base URL, and connection parameters for each worker type directly in the pipeline TOML without modifying worker code. Workers read these values at construction time in spawn_pipeline_with_config.

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<'de> Deserialize<'de> for PipelineConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PipelineConfig

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for PipelineConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for PipelineConfig