Struct RealTimeEmbeddingPipeline 

pub struct RealTimeEmbeddingPipeline { /* private fields */ }

Real-time embedding pipeline for streaming updates

Implementations

impl RealTimeEmbeddingPipeline

pub fn new(config: PipelineConfig) -> PipelineResult<Self>

Create a new real-time embedding pipeline

pub async fn start(&self) -> PipelineResult<()>

Start the pipeline

pub async fn stop(&self) -> PipelineResult<()>

Stop the pipeline

pub fn add_embedding_generator( &self, name: String, generator: Box<dyn EmbeddingGenerator>, ) -> PipelineResult<()>

Add an embedding generator

pub fn add_vector_index( &self, name: String, index: Box<dyn IncrementalVectorIndex>, ) -> PipelineResult<()>

Add a vector index

pub async fn create_stream( &self, config: StreamConfig, ) -> PipelineResult<String>

Create a new stream processor

pub async fn remove_stream(&self, stream_id: &str) -> PipelineResult<()>

Remove a stream processor

pub fn get_statistics(&self) -> Arc<PipelineStatistics>

Get pipeline statistics

pub async fn health_check(&self) -> PipelineResult<HealthCheckResult>

Get pipeline health status

pub fn is_running(&self) -> bool

Check if the pipeline is running

pub fn get_config(&self) -> &PipelineConfig

Get pipeline configuration

pub async fn update_config( &mut self, new_config: PipelineConfig, ) -> PipelineResult<()>

Update pipeline configuration (for some settings)

pub fn list_embedding_generators(&self) -> PipelineResult<Vec<String>>

Get list of available embedding generators

pub fn list_vector_indices(&self) -> PipelineResult<Vec<String>>

Get list of available vector indices

pub fn list_streams(&self) -> PipelineResult<Vec<String>>

Get list of active streams

Trait Implementations

impl Drop for RealTimeEmbeddingPipeline

fn drop(&mut self)

Executes the destructor for this type.