[go: up one dir, main page]

kube 0.32.0

Kubernetes client in futures controller runtime
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
45
46
47
48
49
50
51
52
53

#[macro_use] extern crate log;
use k8s_openapi::api::core::v1::Event;
use kube::{
    api::{Api, ListParams, WatchEvent},
    runtime::Informer,
    Client,
};

use futures::{StreamExt, TryStreamExt};

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    std::env::set_var("RUST_LOG", "info,kube=debug");
    env_logger::init();
    let client = Client::try_default().await?;

    let events: Api<Event> = Api::all(client);
    let lp = ListParams::default();
    let ei = Informer::new(events).params(lp);

    loop {
        let mut events = ei.poll().await?.boxed();

        while let Some(event) = events.try_next().await? {
            handle_event(event)?;
        }
    }
}

// This function lets the app handle an event from kube
fn handle_event(ev: WatchEvent<Event>) -> anyhow::Result<()> {
    match ev {
        WatchEvent::Added(o) => {
            info!(
                "New Event: {} (via {} {})",
                o.message.unwrap(),
                o.involved_object.kind.unwrap(),
                o.involved_object.name.unwrap()
            );
        }
        WatchEvent::Modified(o) => {
            info!("Modified Event: {}", o.reason.unwrap());
        }
        WatchEvent::Deleted(o) => {
            info!("Deleted Event: {}", o.message.unwrap());
        }
        WatchEvent::Error(e) => {
            warn!("Error event: {:?}", e);
        }
        _ => {}
    }
    Ok(())
}