Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Centralized service registry for managing discovered and registered services

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create a new service registry

pub fn with_settings(default_ttl: Duration, max_services: usize) -> Self

Create a new service registry with custom settings

pub async fn register_local_service( &self, service: ServiceInfo, protocol: ProtocolType, ) -> Result<()>

Register a local service

pub async fn unregister_local_service(&self, service_id: &str) -> Result<()>

Unregister a local service

pub async fn add_discovered_service( &self, service: ServiceInfo, protocol: ProtocolType, ttl: Option<Duration>, ) -> Result<()>

Add a discovered service

pub async fn find_services(&self, filter: &ServiceFilter) -> Vec<ServiceInfo>

Find services matching the given filter

pub async fn get_local_services(&self) -> Vec<ServiceInfo>

Get all locally registered services

pub async fn get_discovered_services(&self) -> Vec<ServiceInfo>

Get all discovered services

pub async fn get_services_by_type( &self, service_type: &ServiceType, ) -> Vec<ServiceInfo>

Get services by type

pub async fn get_services_by_protocol( &self, protocol: ProtocolType, ) -> Vec<ServiceInfo>

Get services by protocol

pub async fn is_local_service(&self, service_id: &str) -> bool

Check if a service is registered locally

pub async fn contains_service(&self, service_id: &str) -> bool

Check if a service exists in the registry

pub async fn cleanup_expired(&self) -> usize

Clean up expired services

pub async fn stats(&self) -> RegistryStats

Get registry statistics

Trait Implementations

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.