rcfe 0.1.2

An asynchronous etcd v3 client library for Rust built on gRPC.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use rcfe_core::{
    error::Error,
    options::client::ClientOptions,
    options::kv::KVOptions,
    client::Client,
    kv::KVClient
};
use tonic::transport::Channel;
use crate::kv::DefaultKVClient;

#[derive(Clone)]
pub struct DefaultClient {
    options: ClientOptions,
    kv_client: DefaultKVClient,
}

impl DefaultClient {
    pub fn new(opts: ClientOptions) -> Result<Self, Error> {
        let endpoints = opts
            .endpoints()
            .clone()
            .into_iter()
            .map(Channel::from_shared)
            .collect::<Result<Vec<_>, _>>()?
            .into_iter();

        let channel = Channel::balance_list(endpoints);

        Ok(DefaultClient {
            options: opts,
            kv_client: DefaultKVClient::new(KVOptions::builder().channel(channel.clone()).build()?),
        })
    }
}

impl Client for DefaultClient {
    fn get_options(&self) -> &ClientOptions {
        &self.options
    }

    fn get_kv_client(&self) -> impl KVClient {
        self.kv_client.clone()
    }
}