Struct MiddlewareChain 

pub struct MiddlewareChain { /* private fields */ }

Ordered chain of middleware.

Implementations

impl MiddlewareChain

pub fn new() -> Self

Create a new empty middleware chain.

pub fn add(&mut self, middleware: Arc<dyn Middleware>)

Append a middleware to the end of the chain.

pub fn prepend(&mut self, middleware: Arc<dyn Middleware>)

Prepend a middleware to the front of the chain.

pub async fn run_before_agent( &self, ctx: &InvocationContext, ) -> Result<(), AgentError>

Run all before_agent hooks in order.

pub async fn run_after_agent( &self, ctx: &InvocationContext, ) -> Result<(), AgentError>

Run all after_agent hooks in reverse order.

pub async fn run_before_tool( &self, call: &FunctionCall, ) -> Result<(), AgentError>

Run all before_tool hooks in order.

pub async fn run_after_tool( &self, call: &FunctionCall, result: &Value, ) -> Result<(), AgentError>

Run all after_tool hooks in reverse order.

pub async fn run_on_tool_error( &self, call: &FunctionCall, err: &ToolError, ) -> Result<(), AgentError>

Run all on_tool_error hooks in order.

pub async fn run_on_event(&self, event: &AgentEvent) -> Result<(), AgentError>

Run all on_event hooks in order.

pub async fn run_on_error(&self, err: &AgentError) -> Result<(), AgentError>

Run all on_error hooks in order.

pub async fn run_before_model( &self, request: &LlmRequest, ) -> Result<Option<LlmResponse>, AgentError>

Run all before_model hooks in order. Returns the first non-None override response.

pub async fn run_after_model( &self, request: &LlmRequest, response: &LlmResponse, ) -> Result<Option<LlmResponse>, AgentError>

Run all after_model hooks in reverse order. Returns the first non-None override response.

pub fn is_empty(&self) -> bool

Whether the chain has no middleware layers.

pub fn len(&self) -> usize

Number of middleware layers in the chain.

Trait Implementations

impl Clone for MiddlewareChain

fn clone(&self) -> MiddlewareChain

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MiddlewareChain

fn default() -> MiddlewareChain

Returns the “default value” for a type.