Struct ModuleManager 

pub struct ModuleManager { /* private fields */ }

Central registry that tracks all running module instances in the system. Provides discovery, health tracking, and round-robin load balancing.

Implementations

impl ModuleManager

pub fn new() -> Self

pub fn with_heartbeat_policy(self, ttl: Duration, grace: Duration) -> Self

pub fn register_instance(&self, instance: Arc<ModuleInstance>)

Register or update a module instance

pub fn mark_ready(&self, module: &str, instance_id: Uuid)

Mark an instance as ready

pub fn update_heartbeat(&self, module: &str, instance_id: Uuid, at: Instant)

Update the heartbeat timestamp for an instance

pub fn mark_quarantined(&self, module: &str, instance_id: Uuid)

Mark an instance as quarantined

pub fn mark_draining(&self, module: &str, instance_id: Uuid)

Mark an instance as draining (graceful shutdown in progress)

pub fn deregister(&self, module: &str, instance_id: Uuid)

Remove an instance from the directory

pub fn instances_of(&self, module: &str) -> Vec<Arc<ModuleInstance>>

Get all instances of a specific module

pub fn all_instances(&self) -> Vec<Arc<ModuleInstance>>

Get all instances across all modules

pub fn evict_stale(&self, now: Instant)

Quarantine or evict stale instances based on heartbeat policy

pub fn pick_instance_round_robin( &self, module: &str, ) -> Option<Arc<ModuleInstance>>

Pick an instance using round-robin selection, preferring healthy instances

pub fn pick_service_round_robin( &self, service_name: &str, ) -> Option<(String, Arc<ModuleInstance>, Endpoint)>

Pick a service endpoint using round-robin, returning (module, instance, endpoint). Prefers healthy/ready instances and automatically rotates among them.

Trait Implementations

impl Clone for ModuleManager

fn clone(&self) -> ModuleManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ModuleManager

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

Formats the value using the given formatter.

impl Default for ModuleManager

fn default() -> Self

Returns the “default value” for a type.