Struct GearManager 

pub struct GearManager { /* private fields */ }

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

Implementations

impl GearManager

pub fn new() -> Self

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

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

Register or update a gear instance

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

Mark an instance as ready

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

Update the heartbeat timestamp for an instance

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

Mark an instance as quarantined

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

Mark an instance as draining (graceful shutdown in progress)

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

Remove an instance from the directory

pub fn instances_of(&self, gear: &str) -> Vec<Arc<GearInstance>>

Get all instances of a specific gear

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

Get all instances across all gears

pub fn evict_stale(&self, now: Instant)

Quarantine or evict stale instances based on heartbeat policy

pub fn pick_instance_round_robin(&self, gear: &str) -> Option<Arc<GearInstance>>

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

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

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

pub fn pick_rest_endpoint_round_robin(&self, gear: &str) -> Option<Endpoint>

Resolve a REST endpoint for a gear using round-robin over instances that expose one, preferring healthy/ready instances.

pub fn openapi_spec_of(&self, gear: &str) -> Option<String>

Retrieve the OpenAPI spec of a gear, taken from the first registered instance that published one.

Trait Implementations

impl Clone for GearManager

fn clone(&self) -> GearManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GearManager

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

Formats the value using the given formatter.

impl Default for GearManager

fn default() -> Self

Returns the “default value” for a type.