Struct MessagePipeline

pub struct MessagePipeline { /* private fields */ }

Message processing pipeline

Implementations

impl MessagePipeline

pub async fn new(config: &BotConfig) -> Result<Self>

Create a new message pipeline

Errors

Returns an error if pipeline initialization fails.

pub async fn process( &self, message: Message, context: Arc<RwLock<Context>>, ) -> Result<Response>

Process a message through the pipeline

Errors

Returns an error if any stage in the pipeline fails

pub fn add_stage(&mut self, stage: Box<dyn PipelineStage>)

Add a custom stage to the pipeline

pub fn add_middleware(&mut self, middleware: Box<dyn PipelineMiddleware>)

Add middleware to the pipeline

pub fn metrics(&self) -> &PipelineMetrics

Get pipeline metrics