detcd 0.1.4

An etcd-based implementation of service registration and discovery.
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

use std::time::Duration;
use tokio::time::sleep;
use detcd::client::Builder;
use detcd::history::{History, HistoryType};
use detector::{Meta, MetaKey};

#[tokio::main]
async fn main() {
    println!("{:?}", run1().await);
}

async fn run1() -> Result<(), detcd::Error> {
    let client = Builder::new().build(&["localhost:2379"]).await?;
    let mut history = History::<Meta, MetaKey>::new(client, HistoryType::Metas("default".to_string()));
    loop {
        match history.event().await {
            Ok(e) => println!("{:?}", e),
            Err(old) => {
                println!("olds: {:?}", old);
                sleep(Duration::from_secs(3)).await;
            }
        }
    }
}