Struct ServiceRegistry 

pub struct ServiceRegistry { /* private fields */ }

Thread-safe runtime registry for ScrapingService adapters.

Use ServiceRegistry::builder() for ergonomic setup, or call ServiceRegistry::register at runtime for dynamic registration.

Thread safety

All mutations are guarded by an RwLock. Reads are non-exclusive.

Implementations

impl ServiceRegistry

pub fn new() -> Self

Create an empty registry.

Example

use stygian_graph::application::registry::ServiceRegistry;

let r = ServiceRegistry::new();
assert!(r.get("anything").is_none());

pub fn builder() -> RegistryBuilder

Return a new RegistryBuilder for ergonomic construction.

Example

use stygian_graph::application::registry::ServiceRegistry;
use stygian_graph::adapters::noop::NoopService;
use std::sync::Arc;

let r = ServiceRegistry::builder()
    .register("noop", Arc::new(NoopService))
    .build();

assert!(r.get("noop").is_some());

pub fn register(&self, name: String, service: Arc<dyn ScrapingService>)

Register (or replace) a service at runtime.

The service’s initial status is set to ServiceStatus::Unknown.

Example

use stygian_graph::application::registry::ServiceRegistry;
use stygian_graph::adapters::noop::NoopService;
use std::sync::Arc;

let r = ServiceRegistry::new();
r.register("noop".to_string(), Arc::new(NoopService));
assert!(r.get("noop").is_some());

pub fn get(&self, name: &str) -> Option<Arc<dyn ScrapingService>>

Look up a service by name.

Returns None if the service is not registered.

pub fn status(&self, name: &str) -> Option<ServiceStatus>

Return the current ServiceStatus for the named service.

Returns None if no service is registered under that name.

pub fn names(&self) -> Vec<String>

List all registered service names.

Example

use stygian_graph::application::registry::ServiceRegistry;
use stygian_graph::adapters::noop::NoopService;
use std::sync::Arc;

let r = ServiceRegistry::new();
r.register("a".to_string(), Arc::new(NoopService));
r.register("b".to_string(), Arc::new(NoopService));
let mut names = r.names();
names.sort();
assert_eq!(names, vec!["a", "b"]);

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

Remove a service from the registry.

Returns true if a service was removed, false if it was not registered.

pub async fn health_check_all(&self) -> HashMap<String, ServiceStatus>

Run a simple connectivity health check on all registered services.

Each service’s name is pinged by executing a crate::ports::ServiceInput with a no-op URL. Results update the stored ServiceStatus. Returns a snapshot map of name → status after the checks complete.

pub fn update_status(&self, name: &str, status: ServiceStatus)

Update stored status for a named service directly.

Useful for external health-check feedback (e.g., from readiness probes).

Trait Implementations

impl Default for ServiceRegistry

fn default() -> Self

Returns the “default value” for a type.