Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Production-ready service registry for the ZLayer reverse proxy.

Routes are stored as a Vec<RouteEntry> behind a tokio::sync::RwLock, kept in longest-prefix-first order so that resolve() always returns the most specific match.

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create an empty registry.

pub async fn register(&self, entry: RouteEntry)

Register a route, maintaining longest-prefix-first order.

pub async fn unregister_service(&self, service_name: &str)

Remove all routes belonging to service_name.

pub async fn resolve( &self, host: Option<&str>, path: &str, ) -> Option<ResolvedService>

Resolve an incoming request to the best-matching ResolvedService.

Returns None when no route matches.

pub async fn update_backends( &self, service_name: &str, backends: Vec<SocketAddr>, )

Replace the backend list for every route belonging to service_name.

pub async fn add_backend(&self, service_name: &str, addr: SocketAddr)

Append a single backend address to every route belonging to service_name.

pub async fn remove_backend(&self, service_name: &str, addr: SocketAddr)

Remove a single backend address from every route belonging to service_name.

pub async fn list_services(&self) -> Vec<String>

Return the unique set of service names across all registered routes.

pub async fn route_count(&self) -> usize

Return the total number of registered routes.

pub async fn list_routes(&self) -> Vec<RouteEntry>

Return a snapshot of all registered routes.

Trait Implementations

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.