Struct ExecutionLogTelemetry 

pub struct ExecutionLogTelemetry { /* private fields */ }

将执行日志与 Telemetry 桥接的实现。

实现 Telemetry trait， 将事件生命周期事件记录到 ExecutionLog 中。

Example

use anycms_event::prelude::*;
use anycms_event::execution_log::{ExecutionLog, ExecutionLogTelemetry};

let log = ExecutionLog::in_memory();
let telemetry = ExecutionLogTelemetry::new(log);

let bus = EventBus::builder()
    .telemetry(telemetry)
    .build();

Implementations

impl ExecutionLogTelemetry

pub fn new(log: ExecutionLog) -> Self

创建新的执行日志遥测。

Trait Implementations

impl Telemetry for ExecutionLogTelemetry

fn on_publish(&self, event_name: &str, receivers: usize)

事件发布时调用。

fn on_publish_complete(&self, _event_name: &str, _elapsed: Duration)

事件发布完成后调用。

fn on_subscribe(&self, _event_name: &str, _sub_id: usize)

订阅者注册时调用。

fn on_handler_start(&self, _event_name: &str, _sub_id: usize)

Handler 执行前调用。

fn on_handler_complete( &self, event_name: &str, sub_id: usize, elapsed: Duration, error: Option<&str>, )

Handler 执行完成后调用。error 为 Some 表示 handler 返回了错误。

fn on_handler_lagged( &self, event_name: &str, sub_id: usize, lagged_count: usize, )

Handler 滞后时调用（broadcast channel lagged）。