Struct DMSCServiceRegistry 

pub struct DMSCServiceRegistry { /* private fields */ }

Implementations

impl DMSCServiceRegistry

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

pub async fn register_service( &self, instance: DMSCServiceInstance, ) -> DMSCResult<()>

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

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

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

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

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

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

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

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

Sync registry from etcd

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

Start etcd watcher to sync changes in real-time

Trait Implementations

impl Clone for DMSCServiceRegistry

fn clone(&self) -> DMSCServiceRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DMSCServiceRegistry

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

Formats the value using the given formatter.

impl Default for DMSCServiceRegistry

fn default() -> Self

Returns the “default value” for a type.