hws 0.3.0

Heyo Web Services SDK: create and manage workloads on app-lb, read their telemetry, and the `heyctl` CLI
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

//! Create a workload in your namespace, collect its telemetry, read its logs,
//! roll it to a new image and delete it — with nothing but a namespace token.
//!
//! ```sh
//! HEYCTL_SERVER=https://admin.example.com HEYCTL_TOKEN=applb_… \
//!     cargo run --example namespace_workload
//! ```
//!
//! Kept identical to the quick start in the README.

use hws::{Client, LogQuery};
use serde_json::json;
use std::time::Duration;

#[tokio::main]
async fn main() -> hws::Result<()> {
    let lb = Client::builder(
        std::env::var("HEYCTL_SERVER").unwrap_or_else(|_| "http://127.0.0.1:9090".into()),
    )
    .token(std::env::var("HEYCTL_TOKEN").expect("set HEYCTL_TOKEN"))
    .build()?;

    // Who am I, and where can I deploy?
    let me = lb.whoami().await?;
    let ns = me.sole_namespace().unwrap_or("default").to_string();

    // Create a workload: a managed microVM pool behind a hostname.
    lb.create_deployment(&json!({
        "id": "web",
        "namespace": ns,
        "routes": [{"host": "web.example.com"}],
        "vm": {"image": "nginx-fc", "port": 80},
        "scaling": {"min_replicas": 1, "max_replicas": 4},
    }))
    .await?;
    lb.wait_for_ready("web")
        .timeout(Duration::from_secs(300))
        .await?;

    // Collect its telemetry — once per namespace — and read it back.
    lb.install_plugin(&ns, "obs", None).await?;
    let obs = lb.obs(&ns);
    for d in obs.fleet(Some("1h")).await?.deployments {
        println!(
            "{}: {} log lines, {} errors",
            d.id, d.log_lines, d.error_logs
        );
    }
    for line in obs
        .logs("web", &LogQuery::new().level("error").limit(20))
        .await?
        .rows
    {
        println!("{} {}", line.ts, line.message);
    }

    // Change it: whole-spec replace, or a rollout that verifies the new pool
    // before draining the old one.
    let current = lb.deployment("web").await?;
    let mut spec = lb.raw().spec("web").await?;
    spec["vm"]["image"] = json!("nginx-fc:1.27");
    let op = lb
        .start_rollout("web", "web-1-27", &current.rollout_revision, &spec)
        .await?;
    println!("rollout {} is {}", op.operation_id, op.status);

    lb.delete_deployment("web").await?;
    Ok(())
}