Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

Global registry mapping worker_id → WorkerMailbox.

Shared between spawn_worker (registers on spawn, deregisters on finish) and send_message (looks up the mailbox to push messages).

Implementations

impl WorkerRegistry

pub fn new() -> Self

pub async fn register(&self, worker_id: &str) -> WorkerMailbox

Register a new worker and return its mailbox.

pub async fn deregister(&self, worker_id: &str)

Deregister a worker (called when it finishes).

pub async fn get(&self, worker_id: &str) -> Option<WorkerMailbox>

Get the mailbox for a worker, or None if not registered.

pub async fn active_workers(&self) -> Vec<String>

List active worker IDs.

Trait Implementations

impl Clone for WorkerRegistry

fn clone(&self) -> WorkerRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkerRegistry

fn default() -> WorkerRegistry

Returns the “default value” for a type.