Struct InMemoryWorkerRegistry 

pub struct InMemoryWorkerRegistry { /* private fields */ }

Implementations

impl InMemoryWorkerRegistry

pub fn new() -> Self

Trait Implementations

impl Default for InMemoryWorkerRegistry

fn default() -> Self

Returns the “default value” for a type.

impl WorkerRegistry for InMemoryWorkerRegistry

async fn register( &self, worker_id: &str, labels: &[String], ) -> Result<(), RegistryError>

Register a worker with its capability labels.

async fn heartbeat(&self, worker_id: &str) -> Result<(), RegistryError>

Record a heartbeat from a worker.

async fn deregister(&self, worker_id: &str) -> Result<(), RegistryError>

Remove a worker from the registry.

async fn list_workers(&self) -> Result<Vec<WorkerInfo>, RegistryError>

List all registered workers.

async fn mark_busy( &self, worker_id: &str, job_id: &str, ) -> Result<(), RegistryError>

Mark a worker as busy with a specific job.

async fn mark_idle(&self, worker_id: &str) -> Result<(), RegistryError>

Mark a worker as idle (finished or released a job).