Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

Global registry mapping worker_id → WorkerMailbox.

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) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkerRegistry

fn default() -> Self

Returns the “default value” for a type.