Struct MiddlewareChain 

pub struct MiddlewareChain { /* private fields */ }

中间件链

管理所有中间件并按顺序执行

示例

use flare_core_runtime::middleware::{MiddlewareChain, Middleware};

let mut chain = MiddlewareChain::new();
chain.add(Arc::new(MyMiddleware));

// 执行中间件
chain.before("task-1").await?;
// ... 执行任务 ...
chain.after("task-1", &result).await?;

Implementations

impl MiddlewareChain

pub fn new() -> Self

创建新的中间件链

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

添加中间件

参数

• middleware - 要添加的中间件

pub async fn before(&self, task_name: &str) -> Result<(), MiddlewareError>

执行所有中间件的 before 钩子

按注册顺序执行，如果某个中间件返回错误，则中断链

参数

• task_name - 任务名称

返回

• Ok(()) - 所有中间件执行成功
• Err(MiddlewareError) - 某个中间件返回错误，链被中断

pub async fn after( &self, task_name: &str, result: &Result<(), Box<dyn Error + Send + Sync>>, ) -> Result<(), MiddlewareError>

执行所有中间件的 after 钩子

按注册顺序执行，即使某个中间件失败也继续执行其他中间件

参数

• task_name - 任务名称
• result - 任务执行结果

返回

• Ok(()) - 所有中间件执行成功
• Err(MiddlewareError) - 某个中间件返回错误（但所有中间件都会执行）

pub fn middleware_count(&self) -> usize

获取中间件数量

Trait Implementations

impl Default for MiddlewareChain

fn default() -> Self

Returns the “default value” for a type.