Struct Detector

pub struct Detector { /* private fields */ }

Implementations

impl Detector

pub async fn connect<E: AsRef<str>, S: AsRef<[E]>>( service: Service, endpoints: S, ) -> Result<Detector, Error>

Connect to etcd servers from given endpoints.

pub fn new(client: Client, service: Service) -> Self

Trait Implementations

impl Detector for Detector

async fn register(&mut self) -> Result<(), Box<dyn Error + Send + 'static>>

第一次注册如果失败则返回,如果成功也返回但内部会有掉线重试机制

async fn fetch(&mut self) -> Result<Services, Box<dyn Error + Send + 'static>>

获取本类型服所有实例

async fn fetch_all( &mut self, ) -> Result<HashMap<String, Services>, Box<dyn Error + Send + 'static>>

获取所有注册的服务实例

async fn watch( &mut self, ) -> Result<WatchRx<ServiceEvent>, Box<dyn Error + Send + 'static>>

监听本类型服务实例

async fn watch_all( &mut self, ) -> Result<WatchRx<ServiceEvent>, Box<dyn Error + Send + 'static>>

监听所有注册的服务实例

fn oneself(&mut self) -> Option<OneselfRx>

监听服务自己本身状态, 需要在第一次调用register成功后才能使用它

fn service(&self) -> &Service

本服务数据

fn status(&self) -> ServiceStatus

服务状态

fn id(&self) -> Option<u32>

服务id编号 一旦id有值后则永久不变, 即使被抢占了也不能变 如果id被抢占,那服务状态则会一直是Registering

fn registered(&self) -> bool

是否处于已注册

fn unregistered(&self) -> bool

是否处于注册过期了

impl Drop for Detector

fn drop(&mut self)

Executes the destructor for this type.