Struct DetectMeta

pub struct DetectMeta { /* private fields */ }

Implementations

impl DetectMeta

pub async fn connect<E: AsRef<str>, S: AsRef<[E]>>( meta: Meta, endpoints: S, ) -> Result<DetectMeta, Error>

pub fn new(client: Client, meta: Meta) -> Self

Trait Implementations

impl DetectMeta for DetectMeta

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

注册服务元数据, 不需要ttl

async fn watch(&mut self) -> Result<WatchRx<MetaEvent>, Box<dyn Error>>

监听元数据

async fn fetch(&mut self) -> Result<Option<Meta>, Box<dyn Error>>

获取元数据

async fn fetch_all(&mut self) -> Result<Vec<Meta>, Box<dyn Error>>

获取所有的元数据

async fn watch_all(&mut self) -> Result<WatchRx<MetaEvent>, Box<dyn Error>>

监听所有的元数据