Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Redis-backed service registry for multi-service workspace discovery.

Services register on startup and send periodic heartbeats. Other services discover peers by querying the registry.

Implementations

impl ServiceRegistry

pub fn new(pool: Arc<Pool>) -> Self

Create a new service registry backed by the given Redis pool.

pub async fn register( &self, entry: &ServiceRegistryEntry, ) -> Result<(), ShaperailError>

Register a service in the registry. Sets a TTL so stale entries expire.

pub async fn heartbeat(&self, name: &str) -> Result<(), ShaperailError>

Update heartbeat for a service (refreshes TTL and updates timestamp + status).

pub async fn deregister(&self, name: &str) -> Result<(), ShaperailError>

Deregister a service (mark as stopped and remove).

pub async fn lookup( &self, name: &str, ) -> Result<Option<ServiceRegistryEntry>, ShaperailError>

Look up a service by name.

pub async fn list_services( &self, ) -> Result<Vec<ServiceRegistryEntry>, ShaperailError>

List all registered services.

pub async fn discover_resource( &self, resource_name: &str, ) -> Result<Option<ServiceRegistryEntry>, ShaperailError>

Discover a service that exposes a specific resource.

pub fn start_heartbeat(&self, name: String) -> JoinHandle<()>

Start a background heartbeat task for the given service name. Returns a tokio::task::JoinHandle that can be aborted on shutdown.

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.