Struct ContextPipelineComponent 

pub struct ContextPipelineComponent { /* private fields */ }

Component wrapper for ContextPipeline.

Trait Implementations

impl Component for ContextPipelineComponent

const NAME: &'static str = "context.pipeline"

Stable identifier for the component kind (e.g. "provider.openai", "store.session.redis"). Used in configuration and logging.

type Config = ContextPipelineConfig

Configuration shape. Must be deserializable from JSON/YAML/TOML and must produce a valid JSON Schema for documentation and validation.

type Error = ComponentError

Error type for lifecycle phases. Must implement std::error::Error so the registry can chain and format errors uniformly.

fn init<'life0, 'life1, 'async_trait>( cfg: &'life0 <ContextPipelineComponent as Component>::Config, _ctx: &'life1 ComponentContext, ) -> Pin<Box<dyn Future<Output = Result<ContextPipelineComponent, <ContextPipelineComponent as Component>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ContextPipelineComponent: 'async_trait,

Construct a component instance from its validated configuration.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Begin serving. Default is a no-op. Override to spawn workers, open connections, or warm caches.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Stop serving. Default is a no-op. Override to drain queues, close connections, and persist state.

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Non-mutating health probe. Default is HealthStatus::healthy. Override to surface upstream connectivity, queue depth, retry pressure, etc.

fn depends_on() -> &'static [&'static str]

Names of components this component depends on. Used by the registry to build a dependency graph and drive ordered initialization.

fn pre_replace_hook<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Called before this component is replaced by a new instance.

fn post_replace_hook<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Called after this component has been replaced by a new instance.