Struct ExtensiblePipelineConfig 

pub struct ExtensiblePipelineConfig {
    pub enabled: bool,
    pub global_settings: GlobalPipelineSettings,
    pub stage_configs: HashMap<String, Value>,
    pub stage_order: Option<Vec<String>>,
    pub enabled_stages: Option<Vec<String>>,
    pub disabled_stages: Option<Vec<String>>,
}

Configuration for the extensible pipeline system.

Fields

enabled: bool

Whether to use the extensible pipeline system

global_settings: GlobalPipelineSettings

Global pipeline settings

stage_configs: HashMap<String, Value>

Stage-specific configurations

stage_order: Option<Vec<String>>

Stage execution order (if not specified, dependencies will determine order)

enabled_stages: Option<Vec<String>>

Stages to enable/disable

disabled_stages: Option<Vec<String>>

Implementations

impl ExtensiblePipelineConfig

This impl block contains no items.

Utility functions for working with extensible pipeline configurations.

impl ExtensiblePipelineConfig

Utility functions for working with extensible pipeline configurations.

pub fn get_stage_config<T>(&self, stage_id: &str) -> Option<T>

where T: for<'de> Deserialize<'de>,

Get configuration for a specific stage.

pub fn is_stage_enabled(&self, stage_id: &str) -> bool

Check if a stage is enabled.

pub fn get_stage_order(&self) -> Option<Vec<StageId>>

Get the configured stage execution order.

impl ExtensiblePipelineConfig

Configuration validation utilities.

pub fn validate(&self) -> Result<(), ConfigError>

Validate the configuration for consistency and correctness.

Trait Implementations

impl Clone for ExtensiblePipelineConfig

fn clone(&self) -> ExtensiblePipelineConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConfigValidator for ExtensiblePipelineConfig

Implementation of ConfigValidator trait for ExtensiblePipelineConfig.

fn validate(&self) -> Result<(), ConfigError>

Validate the configuration for consistency and correctness.

This implementation delegates to the existing validate method to maintain consistency with the structured error handling used throughout the codebase.

fn get_defaults() -> Self

Get default configuration.

fn validate_batch_size(&self, batch_size: usize) -> Result<(), ConfigError>

Validates a batch size.

fn validate_batch_size_with_limits( &self, batch_size: usize, max_batch_size: usize, ) -> Result<(), ConfigError>

Validates a batch size against limits.

fn validate_model_path(&self, path: &Path) -> Result<(), ConfigError>

Validates a model path.

fn validate_image_dimensions( &self, width: u32, height: u32, ) -> Result<(), ConfigError>

Validates image dimensions.

fn validate_confidence_threshold( &self, threshold: f32, ) -> Result<(), ConfigError>

Validates a confidence threshold.

fn validate_memory_limit(&self, limit_mb: usize) -> Result<(), ConfigError>

Validates a memory limit.

fn validate_thread_count(&self, thread_count: usize) -> Result<(), ConfigError>

Validates thread count.

fn validate_f32_range( &self, value: f32, min: f32, max: f32, field_name: &str, ) -> Result<(), ConfigError>

Validates a float value is within a specified range.

fn validate_positive_f32( &self, value: f32, field_name: &str, ) -> Result<(), ConfigError>

Validates a float value is positive.

fn validate_positive_usize( &self, value: usize, field_name: &str, ) -> Result<(), ConfigError>

Validates a usize value is positive.

impl Debug for ExtensiblePipelineConfig

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

Formats the value using the given formatter.

impl Default for ExtensiblePipelineConfig

fn default() -> ExtensiblePipelineConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ExtensiblePipelineConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ExtensiblePipelineConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.