Merge pull request #55 from thomastaylor312/feat/cache

feat!(kv): Adds caching option for the interface client

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "wasmcloud-control-interface"
-version = "0.28.1"
+version = "0.29.0-rc.1"
 authors = ["wasmCloud Team"]
 edition = "2021"
 homepage = "https://wasmcloud.com"
@@ -14,12 +14,13 @@ categories = ["wasm", "api-bindings"]
 
 [dependencies]
 async-nats = "0.31"
+async-trait = "0.1"
 data-encoding = "2.3.3"
 ring = "0.16.20"
 cloudevents-sdk = "0.7.0"
 futures = "0.3"
 rmp-serde = "1.0.0"
-tokio = { version="1.9", features=["time"] }
+tokio = { version = "1.9", features = ["time"] }
 serde = { version = "1.0.118", features = ["derive"] }
 serde_json = "1.0.60"
 tracing = "0.1.37"
@@ -28,3 +29,6 @@ bytes = "1.4.0"
 opentelemetry = "0.19.0"
 tracing-opentelemetry = "0.19.0"
 lazy_static = "1.4.0"
+
+[dev-dependencies]
+rstest = "0.18"

src/broker.rs

@@ -23,14 +23,6 @@ pub fn actor_auction_subject(topic_prefix: &Option<String>, lattice_prefix: &str
     format!("{}.auction.actor", prefix(topic_prefix, lattice_prefix))
 }
 
-pub fn advertise_link(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
-    format!("{}.linkdefs.put", prefix(topic_prefix, lattice_prefix))
-}
-
-pub fn remove_link(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
-    format!("{}.linkdefs.del", prefix(topic_prefix, lattice_prefix))
-}
-
 pub fn publish_registries(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
     format!("{}.registries.put", prefix(topic_prefix, lattice_prefix))
 }
@@ -83,14 +75,6 @@ pub mod commands {
 pub mod queries {
     use super::prefix;
 
-    pub fn link_definitions(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
-        format!("{}.get.links", prefix(topic_prefix, lattice_prefix))
-    }
-
-    pub fn claims(topic_prefix: &Option<String>, lattice_prefix: &str) -> String {
-        format!("{}.get.claims", prefix(topic_prefix, lattice_prefix))
-    }
-
     pub fn host_inventory(
         topic_prefix: &Option<String>,
         lattice_prefix: &str,