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
26
27
28
29
30

use detcd::client::Builder;
use detector::MetaKey;

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

#[warn(dead_code)]
async fn run1() -> Result<(), detcd::Error> {
    let mut client = Builder::new().build(&["localhost:2379"]).await?;
    let mut w = client.watch_metas("dev").await?;
    while let Ok(e) = w.event().await {
        println!("{:?}", e);
    }
    println!("over");
    Ok(())
}

#[warn(dead_code)]
async fn run2() -> Result<(), detcd::Error> {
    let mut client = Builder::new().build(&["localhost:2379"]).await?;
    let mut w = client.watch_meta(&MetaKey::new("game", "dev")).await?;
    while let Ok(e) = w.event().await {
        println!("{:?}", e);
    }
    println!("over");
    Ok(())
}