Struct RiServiceRegistry 

pub struct RiServiceRegistry { /* private fields */ }

Implementations

impl RiServiceRegistry

pub fn new(etcd_client: Option<Client>, etcd_prefix: String) -> Self

pub async fn register_service( &self, instance: RiServiceInstance, ) -> RiResult<()>

pub async fn deregister_service(&self, instance_id: &str) -> RiResult<()>

pub async fn get_service_instances( &self, service_name: &str, ) -> RiResult<Vec<RiServiceInstance>>

pub async fn get_all_services(&self) -> RiResult<Vec<String>>

pub async fn update_heartbeat(&self, instance_id: &str) -> RiResult<()>

pub async fn update_instance_status( &self, instance_id: &str, status: RiServiceStatus, ) -> RiResult<()>

pub async fn get_healthy_instances( &self, service_name: &str, ) -> RiResult<Vec<RiServiceInstance>>

pub async fn cleanup_expired_instances( &self, expiration_duration: Duration, ) -> RiResult<()>

pub async fn sync_from_etcd(&self) -> RiResult<()>

Sync registry from etcd

pub async fn start_etcd_watcher(&self) -> RiResult<JoinHandle<()>>

Start etcd watcher to sync changes in real-time

Trait Implementations

impl Clone for RiServiceRegistry

fn clone(&self) -> RiServiceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RiServiceRegistry

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

Formats the value using the given formatter.

impl Default for RiServiceRegistry

fn default() -> Self

Returns the “default value” for a type.