Struct NotificationProducer 

pub struct NotificationProducer { /* private fields */ }

已冻结 provider 目录的队列生产能力。

Implementations

impl NotificationProducer

pub fn route(&self, provider_ref: &str) -> Option<AlertRoute>

业务作用：在启动期把名称解析为可在热路径直接使用的队列路由。

参数说明：

• provider_ref：必须来自经过校验的冻结配置。

返回：对应路由；未知 provider 返回 None。

pub fn default_route(&self) -> Option<AlertRoute>

业务作用：取得使用进程通知实现的非阻塞路由，未初始化时通知不进入队列。

参数说明：无。

返回：目录包含默认路由时返回生产能力；其它目录返回 None，不增建 provider 或指标维度。

pub fn close(&self)

业务作用：先撤销所有生产路由的接受权，再由宿主排空已接受消息。

参数说明：无。

返回：无；重复关闭没有额外副作用。

pub fn metrics(&self) -> Arc<QueueMetrics>

业务作用：交出只持有原子单元的统一指标源。

参数说明：无。

返回：与生产端、worker 同源的指标句柄。

Trait Implementations

impl Clone for NotificationProducer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.