Trait WorkerRegistry 

pub trait WorkerRegistry:
    Send
    + Sync
    + 'static {
    // Required methods
    fn register(
        &self,
        worker_id: &str,
        labels: &[String],
    ) -> impl Future<Output = Result<(), RegistryError>> + Send;
    fn heartbeat(
        &self,
        worker_id: &str,
    ) -> impl Future<Output = Result<(), RegistryError>> + Send;
    fn deregister(
        &self,
        worker_id: &str,
    ) -> impl Future<Output = Result<(), RegistryError>> + Send;
    fn list_workers(
        &self,
    ) -> impl Future<Output = Result<Vec<WorkerInfo>, RegistryError>> + Send;
    fn mark_busy(
        &self,
        worker_id: &str,
        job_id: &str,
    ) -> impl Future<Output = Result<(), RegistryError>> + Send;
    fn mark_idle(
        &self,
        worker_id: &str,
    ) -> impl Future<Output = Result<(), RegistryError>> + Send;
}

Registry of connected workers and their capabilities.

Used for monitoring and matching jobs to capable workers.

Required Methods

fn register( &self, worker_id: &str, labels: &[String], ) -> impl Future<Output = Result<(), RegistryError>> + Send

Register a worker with its capability labels.

fn heartbeat( &self, worker_id: &str, ) -> impl Future<Output = Result<(), RegistryError>> + Send

Record a heartbeat from a worker.

fn deregister( &self, worker_id: &str, ) -> impl Future<Output = Result<(), RegistryError>> + Send

Remove a worker from the registry.

fn list_workers( &self, ) -> impl Future<Output = Result<Vec<WorkerInfo>, RegistryError>> + Send

List all registered workers.

fn mark_busy( &self, worker_id: &str, job_id: &str, ) -> impl Future<Output = Result<(), RegistryError>> + Send

Mark a worker as busy with a specific job.

fn mark_idle( &self, worker_id: &str, ) -> impl Future<Output = Result<(), RegistryError>> + Send

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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl WorkerRegistry for InMemoryWorkerRegistry