wasmcloud-control-interface 0.19.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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

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

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

pub fn control_event(ns_prefix: &Option<String>) -> String {
    format!(
        "{}.{}",
        EVT_TOPIC_PREFIX,
        ns_prefix.as_ref().unwrap_or(&DEFAULT_NS_PREFIX.to_string())
    )
}

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

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

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

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

pub fn publish_registries(topic_prefix: &Option<String>, ns_prefix: &Option<String>) -> 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: &Option<String>,
        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: &Option<String>,
        host: &str,
    ) -> String {
        format!("{}.cmd.{}.scale", prefix(topic_prefix, ns_prefix), host)
    }

    pub fn stop_actor(
        topic_prefix: &Option<String>,
        ns_prefix: &Option<String>,
        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: &Option<String>,
        host: &str,
    ) -> String {
        format!("{}.cmd.{}.lp", prefix(topic_prefix, ns_prefix), host)
    }

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

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

    pub fn stop_host(
        topic_prefix: &Option<String>,
        ns_prefix: &Option<String>,
        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: &Option<String>) -> String {
        format!("{}.get.links", prefix(topic_prefix, ns_prefix))
    }

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

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

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