Struct WorkerRegistry 

pub struct WorkerRegistry { /* private fields */ }

Worker registry for persistent storage

Implementations

impl WorkerRegistry

pub fn new(backend: RegistryBackend) -> Self

Create a new worker registry

pub async fn register( &self, worker_id: String, endpoint: WorkerEndpoint, ) -> Result<()>

Register a worker

pub async fn unregister(&self, worker_id: &str) -> Result<()>

Unregister a worker

pub async fn update_heartbeat(&self, worker_id: &str) -> Result<()>

Update worker heartbeat

pub async fn get_all(&self) -> Vec<RegisteredWorker>

Get all workers