Struct EventBusBuilder 

pub struct EventBusBuilder { /* private fields */ }

EventBus 构建器，提供流畅的配置 API。

Example

use anycms_event::prelude::*;
use anycms_event::telemetry::TracingTelemetry;
use anycms_event::registry::EventRegistry;

let registry = Arc::new(EventRegistry::new());
let bus = EventBus::builder()
    .capacity(2048)
    .telemetry(TracingTelemetry)
    .registry(registry)
    .build();

Implementations

impl EventBusBuilder

pub fn new() -> Self

创建一个新的构建器，使用默认值。

默认容量为 1024，无遥测，自动创建空注册表。

pub fn capacity(self, capacity: usize) -> Self

设置广播通道容量。

容量控制慢订阅者开始被滞后（丢弃旧消息）之前可以缓冲多少消息。

pub fn telemetry<T: Telemetry>(self, telemetry: T) -> Self

设置遥测层。

遥测回调将在事件总线的发布/订阅生命周期中被调用。

pub fn registry(self, registry: Arc<EventRegistry>) -> Self

设置自定义事件注册表。

如果不设置，构建时会自动创建一个空注册表。

pub fn execution_log(self, log: Arc<ExecutionLog>) -> Self

设置执行日志。

执行日志记录事件发布和 Handler 执行的历史记录。 通常与 ExecutionLogTelemetry 一起使用。

pub fn retry_policy(self, policy: RetryPolicy) -> Self

设置 Handler 重试策略。

默认不重试（max_retries: 0）。

pub fn dead_letter_handler<H: DeadLetterHandler>(self, handler: H) -> Self

设置死信处理器。

当 Handler 重试耗尽后，将调用死信处理器。

pub fn build(self) -> EventBus

消费构建器并返回配置好的 EventBus。

Trait Implementations

impl Default for EventBusBuilder

fn default() -> Self

Returns the “default value” for a type.