Struct DispatcherConfig 

pub struct DispatcherConfig {
    pub queue_capacity: usize,
    pub max_in_flight: usize,
    pub delivery_timeout_ms: u64,
    pub shutdown_drain_timeout_ms: u64,
    pub max_attempts: usize,
    pub retry_initial_backoff_ms: u64,
    pub retry_max_backoff_ms: u64,
}

进程级通知调度预算；未启用通知时仅保留配置，不创建运行资源。

Fields

queue_capacity: usize

等待 worker 接收的通知数量上限。

max_in_flight: usize

宿主同时执行的通知投递数量上限。

delivery_timeout_ms: u64

worker 开始投递后覆盖全部尝试与退避的总预算，单位毫秒，不含排队时间。

shutdown_drain_timeout_ms: u64

停机后队列排空预算，单位毫秒，同时受宿主剩余期限约束。

max_attempts: usize

同一通知最多尝试次数，包含首次投递；重试还须有安全证据。

retry_initial_backoff_ms: u64

可安全重试时的初始退避，单位毫秒。

retry_max_backoff_ms: u64

指数退避的上限，单位毫秒；服务端要求的最小等待仍须满足。

Implementations

impl DispatcherConfig

pub fn validate(&self) -> Result<(), ConfigError>

业务作用：在分配队列或调用渠道前验证调度资源和时间上限。

参数说明：无。

返回：配置合法时成功，否则只返回静态字段名。

Trait Implementations

impl Clone for DispatcherConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DispatcherConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DispatcherConfig

fn default() -> Self

业务作用：提供所有宿主共用的有限队列与投递预算。

参数说明：无。

返回：关闭无限等待和无限重试的稳定默认值。

impl<'de> Deserialize<'de> for DispatcherConfig

where DispatcherConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for DispatcherConfig

impl PartialEq for DispatcherConfig

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for DispatcherConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DispatcherConfig