Struct UpstreamPeerRegistry 

pub struct UpstreamPeerRegistry { /* private fields */ }

Registry of upstream session peers that should receive backend notifications.

Implementations

impl UpstreamPeerRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&self, peer: Peer<RoleServer>) -> u64

Register an upstream peer (typically from ServerHandler::on_initialized).

pub fn unregister(&self, id: u64)

Explicitly remove a registered peer by id.

pub fn len(&self) -> usize

Number of registered peers (for diagnostics).

pub fn is_empty(&self) -> bool

Whether the registry has no peers.

pub fn register_progress(&self, token: ProgressToken, peer: Peer<RoleServer>)

Bind a progress token to the upstream peer that owns the request.

pub fn unregister_progress(&self, token: &ProgressToken)

Remove a progress-token route (request finished or cancelled).

pub fn register_task(&self, task_id: impl Into<String>, peer: Peer<RoleServer>)

Bind a task id to the upstream peer that created/enqueued the task.

pub fn unregister_task(&self, task_id: &str)

Remove a task-id route.

pub fn reap_closed_peers(&self)

Drop peers whose transport is already closed (eager cleanup on session close).

pub async fn deliver_progress(&self, params: ProgressNotificationParam)

Deliver a progress notification to the owning upstream peer only.

pub async fn deliver_task_status(&self, params: TaskStatusNotificationParams)

Deliver a task-status notification to the owning upstream peer only.

pub async fn fan_out<F, Fut>(&self, send: F)

where F: FnMut(Peer<RoleServer>) -> Fut, Fut: Future<Output = Result<(), ServiceError>>,

Fan-out a notification to all peers; remove peers that fail to send.

Trait Implementations

impl Debug for UpstreamPeerRegistry

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

Formats the value using the given formatter.

impl Default for UpstreamPeerRegistry

fn default() -> Self

Returns the “default value” for a type.