Added in a first attempt at a solution to sharing watchers between stores and controllers

kube-core/src/params.rs

@@ -3,7 +3,7 @@ use crate::request::Error;
 use serde::Serialize;
 
 /// Common query parameters used in watch/list/delete calls on collections
-#[derive(Clone, Debug)]
+#[derive(Clone, Debug, Eq, Hash, PartialEq)]
 pub struct ListParams {
     /// A selector to restrict the list of returned objects by their labels.
     ///

kube-runtime/Cargo.toml

@@ -35,17 +35,20 @@ json-patch = "0.3.0"
 serde_json = "1.0.68"
 thiserror = "1.0.29"
 backoff = "0.4.0"
+once_cell = "1.8.0"
 
 [dependencies.k8s-openapi]
 version = "0.17.0"
 default-features = false
 
 [dev-dependencies]
 kube = { path = "../kube", features = ["derive", "client", "runtime"], version = "<1.0.0, >=0.60.0" }
+maplit = "1.0.2"
 serde_json = "1.0.68"
 tokio = { version = "1.14.0", features = ["full", "test-util"] }
 rand = "0.8.0"
 schemars = "0.8.6"
+async-trait = "0.1.51"
 
 [dev-dependencies.k8s-openapi]
 version = "0.17.0"

kube-runtime/src/lib.rs

@@ -26,6 +26,7 @@ pub mod scheduler;
 pub mod utils;
 pub mod wait;
 pub mod watcher;
+pub mod shared_store;
 
 pub use controller::{applier, Controller};
 pub use finalizer::finalizer;