Struct DiscoveryService 

pub struct DiscoveryService { /* private fields */ }

Worker discovery service

Implementations

impl DiscoveryService

pub fn new(method: DiscoveryMethod, config: DiscoveryConfig) -> Self

Create a new discovery service

pub async fn start(&self) -> Result<()>

Start the discovery service

pub fn register_worker(&self, endpoint: WorkerEndpoint) -> Result<()>

Register a worker manually

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

Unregister a worker

pub fn get_workers(&self) -> Vec<WorkerEndpoint>

Get all discovered workers

pub fn get_healthy_workers(&self) -> Vec<WorkerEndpoint>

Get healthy workers

pub fn get_worker(&self, worker_id: &str) -> Option<WorkerEndpoint>

Get worker by ID

pub fn find_workers_by_capability( &self, required_codec: &str, ) -> Vec<WorkerEndpoint>

Find workers by capability

pub fn find_workers_by_region(&self, region: &str) -> Vec<WorkerEndpoint>

Find workers by location

pub fn get_capacity_stats(&self) -> CapacityStats

Get capacity statistics

pub async fn stop(&self) -> Result<()>

Stop the discovery service