Struct etcd_discovery::EtcdDiscovery

pub struct EtcdDiscovery { /* private fields */ }

etcd 服务发现

Implementations

impl EtcdDiscovery

pub fn get_all_channel(&self) -> Channel

获取所有服务的channel, 负载均衡的channel

pub fn get_service_map(&self) -> Arc<RwLock<HashMap<String, Channel>>>

获取所有服务的map

pub fn get_etcd_client(&self) -> Client

获取etcd客户端

impl EtcdDiscovery

pub fn new(client: Client) -> Self

用etcd_client创建服务发现

pub async fn connect( etcd_addr: impl AsRef<[&str]>, options: Option<ConnectOptions> ) -> Result<Self, Error>

连接etcd, 创建服务发现

pub async fn service_discover(&mut self, prefix: &str) -> Result<(), Error>

服务发现, prefix为服务前缀, 例如: /hello, 发现前缀/hello的所有服务

pub fn get_service(&self, key: impl AsRef<str>) -> Option<Channel>

获取一个服务的channel, 例如: /hello/1

pub fn remove_service(&mut self, key: impl AsRef<str>) -> Option<Channel>

pub async fn add_service(&self, key: impl AsRef<str>, url: &str)