Struct ServiceRegistry 

pub struct ServiceRegistry {
    services: Arc<RwLock<HashMap<String, LocalService>>>,
    cert_manager: Option<Arc<Mutex<CertificateManager>>>,
}

Registry for tracking local HTTP/HTTPS services

Provides thread-safe methods to register and lookup services by domain name. Supports both HTTP and HTTPS protocols with automatic TLS certificate provisioning.

Fields

services: Arc<RwLock<HashMap<String, LocalService>>>

Inner storage using Arc<RwLock> for thread-safe concurrent access

cert_manager: Option<Arc<Mutex<CertificateManager>>>

Optional certificate manager for HTTPS support

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create a new ServiceRegistry instance

Returns an empty registry ready to accept service registrations.

pub fn with_tls(cert_manager: Arc<Mutex<CertificateManager>>) -> Self

Create a new ServiceRegistry instance with TLS support

Parameters

• cert_manager - Certificate manager for provisioning TLS certificates

Returns a registry ready to accept both HTTP and HTTPS service registrations.

pub fn register( &self, name: String, port: u16, health_check_path: Option<String>, )

Register a local HTTP service

Parameters

• name: Domain name (e.g., “code.editor.land”)
• port: Local port where the service is listening
• health_check_path: Optional path for health check endpoint (e.g., “/health”)

Example

registry.register("code.editor.land".to_string(), 8080, Some("/health".to_string())); 

pub fn register_with_options( &self, name: String, port: u16, tls_port: Option<u16>, use_tls: bool, health_check_path: Option<String>, )

Register a local service with TLS options

Parameters

• name: Domain name (e.g., “code.editor.land”)
• port: Local HTTP port
• tls_port: Optional TLS port (defaults to port + 1000)
• use_tls: Whether to enable HTTPS
• health_check_path: Optional path for health check endpoint

Example

// Register with TLS enabled
registry.register_with_options(
	"code.editor.land".to_string(),
	8080,
	None, // Use default TLS port (9080)
	true,
	Some("/health".to_string()),
);

pub fn lookup(&self, name: &str) -> Option<LocalService>

Look up a service by domain name

Parameters

• name: Domain name to look up

Returns

• Some(LocalService) if found
• None if not registered

Example

let service = registry.lookup("code.editor.land");
if let Some(svc) = service {
	println!("Service running on port {}", svc.port);
}

pub fn all_services(&self) -> Vec<LocalService>

Get all registered services

Returns

A vector of all registered LocalService instances

pub async fn health_check( &self, name: &str, ) -> Result<bool, Box<dyn Error + Send + Sync>>

Perform a health check on a registered service

Parameters

• name: Domain name of the service to check

Returns

• Ok(true) if service is healthy and responding
• Ok(false) if service is not healthy
• Err if service not found or health check fails

pub fn unregister(&self, name: &str) -> Option<LocalService>

Remove a service from the registry

Parameters

• name: Domain name of the service to remove

Returns

• Some(LocalService) if service was removed
• None if service was not found

pub async fn get_tls_config(&self, name: &str) -> Option<Arc<ServerConfig>>

Get TLS configuration for a service (if available)

Parameters

• name: Domain name of the service

Returns

• Some(Arc<ServerConfig>) if service uses TLS and certificate manager is available
• None if service doesn’t use TLS or certificate manager is not configured

pub fn uses_tls(&self, name: &str) -> bool

Check if a service uses TLS

Parameters

• name: Domain name of the service

Returns

true if the service is configured to use TLS, false otherwise

Trait Implementations

impl Clone for ServiceRegistry

fn clone(&self) -> ServiceRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.