wasmcloud-control-interface 0.23.0

A client library for communicating with hosts on a wasmCloud lattice
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

const DEFAULT_TOPIC_PREFIX: &str = "wasmbus.ctl";
const EVT_TOPIC_PREFIX: &str = "wasmbus.evt";

fn prefix(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!(
        "{}.{}",
        topic_prefix
            .as_ref()
            .unwrap_or(&DEFAULT_TOPIC_PREFIX.to_string()),
        ns_prefix
    )
}

pub fn control_event(ns_prefix: &str) -> String {
    format!("{}.{}", EVT_TOPIC_PREFIX, ns_prefix)
}

pub fn provider_auction_subject(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!("{}.auction.provider", prefix(topic_prefix, ns_prefix))
}

pub fn actor_auction_subject(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!("{}.auction.actor", prefix(topic_prefix, ns_prefix))
}

pub fn advertise_link(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!("{}.linkdefs.put", prefix(topic_prefix, ns_prefix))
}

pub fn remove_link(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!("{}.linkdefs.del", prefix(topic_prefix, ns_prefix))
}

pub fn publish_registries(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
    format!("{}.registries.put", prefix(topic_prefix, ns_prefix))
}

pub mod commands {
    use super::prefix;

    /// Actor commands require a host target
    pub fn start_actor(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.la", prefix(topic_prefix, ns_prefix), host) // la - launch actor
    }

    pub fn scale_actor(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.scale", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn stop_actor(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.sa", prefix(topic_prefix, ns_prefix), host) // sa - stop actor
    }

    pub fn start_provider(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.lp", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn stop_provider(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.sp", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn update_actor(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.upd", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn stop_host(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.cmd.{}.stop", prefix(topic_prefix, ns_prefix), host)
    }
}

pub mod queries {
    use super::prefix;

    pub fn link_definitions(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
        format!("{}.get.links", prefix(topic_prefix, ns_prefix))
    }

    pub fn claims(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
        format!("{}.get.claims", prefix(topic_prefix, ns_prefix))
    }

    pub fn host_inventory(topic_prefix: &Option<String>, ns_prefix: &str, host: &str) -> String {
        format!("{}.get.{}.inv", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn hosts(topic_prefix: &Option<String>, ns_prefix: &str) -> String {
        format!("{}.ping.hosts", prefix(topic_prefix, ns_prefix))
    }
}