Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Service registry and discovery.

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create a new service registry.

pub fn with_domain(domain: String) -> Self

Create with a custom domain.

pub fn register(&mut self, entry: ServiceEntry) -> Result<(), DiscoveryError>

Register a new service.

pub fn deregister( &mut self, name: &str, namespace: &str, ) -> Result<ServiceEntry, DiscoveryError>

Deregister a service.

pub fn lookup( &self, name: &str, namespace: &str, ) -> Result<&ServiceEntry, DiscoveryError>

Look up a service by name and namespace.

pub fn list(&self, namespace_filter: Option<&str>) -> Vec<&ServiceEntry>

List all services, optionally filtered by namespace.

pub fn resolve_service_dns( &self, dns_name: &str, ) -> Result<&ServiceEntry, DiscoveryError>

Resolve a Kubernetes-style DNS name to service endpoints.

Format: name.namespace.svc.cluster.local

pub fn fqdn(&self, name: &str, namespace: &str) -> String

Get the fully qualified DNS name for a service.

pub fn healthy_endpoints( &self, name: &str, namespace: &str, ) -> Result<Vec<&ServiceEndpoint>, DiscoveryError>

Get healthy endpoints for a service.

pub fn update_endpoint_health( &mut self, name: &str, namespace: &str, address: &str, healthy: bool, ) -> Result<(), DiscoveryError>

Update endpoint health for a service.

pub fn service_count(&self) -> usize

Get the total number of registered services.

Trait Implementations

impl Debug for ServiceRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.