runtime - fixes #147

CHANGELOG.md

@@ -1,3 +1,7 @@
+0.27.0 / 2020-02-XX
+===================
+ * `Reflector` + `Informer` moved from `kube::api` to `kube::runtime`
+
 0.26.0 / 2020-02-25
 ===================
   * Fix a large percentage of EOFs from watches #146

examples/configmap_reflector.rs

@@ -1,9 +1,5 @@
 #[macro_use] extern crate log;
-use kube::{
-    api::{Api, Reflector},
-    client::APIClient,
-    config,
-};
+use kube::{api::Api, client::APIClient, config, runtime::Reflector};
 
 /// Example way to read secrets
 #[tokio::main]

examples/crd_reflector.rs

@@ -4,9 +4,10 @@ use futures_timer::Delay;
 use std::time::Duration;
 
 use kube::{
-    api::{NotUsed, Object, RawApi, Reflector},
+    api::{NotUsed, Object, RawApi},
     client::APIClient,
     config,
+    runtime::Reflector,
 };
 
 // Own custom resource spec

examples/deployment_reflector.rs

@@ -1,9 +1,5 @@
 #[macro_use] extern crate log;
-use kube::{
-    api::{Api, Reflector},
-    client::APIClient,
-    config,
-};
+use kube::{api::Api, client::APIClient, config, runtime::Reflector};
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {

examples/event_informer.rs

@@ -1,8 +1,9 @@
 #[macro_use] extern crate log;
 use kube::{
-    api::{v1Event, Api, Informer, WatchEvent},
+    api::{v1Event, Api, WatchEvent},
     client::APIClient,
     config,
+    runtime::Informer,
 };
 
 use futures::StreamExt;

examples/node_informer.rs

@@ -2,9 +2,10 @@
 use futures::StreamExt;
 use k8s_openapi::api::core::v1::{NodeSpec, NodeStatus};
 use kube::{
-    api::{v1Event, Api, Informer, ListParams, Object, RawApi, WatchEvent},
+    api::{v1Event, Api, ListParams, Object, RawApi, WatchEvent},
     client::APIClient,
     config,
+    runtime::Informer,
 };
 
 type Node = Object<NodeSpec, NodeStatus>;

examples/node_reflector.rs

@@ -1,10 +1,6 @@
 #[macro_use] extern crate log;
 use futures_timer::Delay;
-use kube::{
-    api::{Api, Reflector},
-    client::APIClient,
-    config,
-};
+use kube::{api::Api, client::APIClient, config, runtime::Reflector};
 
 use std::time::Duration;
 

examples/pod_informer.rs

@@ -2,9 +2,10 @@
 use futures::{StreamExt, TryStreamExt};
 use k8s_openapi::api::core::v1::{PodSpec, PodStatus};
 use kube::{
-    api::{Api, Informer, Object, WatchEvent},
+    api::{Api, Object, WatchEvent},
     client::APIClient,
     config,
+    runtime::Informer,
 };
 use std::env;
 type Pod = Object<PodSpec, PodStatus>;

examples/pod_reflector.rs

@@ -1,10 +1,6 @@
 #[macro_use] extern crate log;
 use futures_timer::Delay;
-use kube::{
-    api::{Api, Reflector},
-    client::APIClient,
-    config,
-};
+use kube::{api::Api, client::APIClient, config, runtime::Reflector};
 use std::time::Duration;
 
 #[tokio::main]

examples/secret_reflector.rs

@@ -1,11 +1,7 @@
 #[macro_use] extern crate log;
 use std::collections::BTreeMap;
 
-use kube::{
-    api::{Api, Reflector},
-    client::APIClient,
-    config,
-};
+use kube::{api::Api, client::APIClient, config, runtime::Reflector};
 
 /// Example way to read secrets
 #[derive(Debug)]

src/api/mod.rs

@@ -11,22 +11,16 @@ pub struct NotUsed {}
 #[deprecated]
 pub type Void = NotUsed;
 
-mod reflector;
-pub use self::reflector::Reflector;
-
-mod informer;
-pub use self::informer::Informer;
-
-mod raw;
+pub(crate) mod raw;
 pub use raw::{DeleteParams, ListParams, PatchParams, PatchStrategy, PostParams, PropagationPolicy, RawApi};
 
-mod typed;
+pub(crate) mod typed;
 pub use typed::Api;
 
 mod subresource;
 pub use subresource::{LogParams, Scale, ScaleSpec, ScaleStatus};
 
-mod resource;
+pub(crate) mod resource;
 pub use self::resource::{KubeObject, Object, ObjectList, WatchEvent};
 
 mod openapi;

src/api/typed.rs

@@ -28,11 +28,11 @@ use crate::{
 #[derive(Clone)]
 pub struct Api<K> {
     /// The request creator object
-    pub(in crate::api) api: RawApi,
+    pub(crate) api: RawApi,
     /// The client to use (from this library)
-    pub(in crate::api) client: APIClient,
-    /// sPec and statUs structs
-    pub(in crate::api) phantom: PhantomData<K>,
+    pub(crate) client: APIClient,
+    /// Underlying Object unstored
+    pub(crate) phantom: PhantomData<K>,
 }
 
 /// Expose same interface as Api for controlling scope/group/versions/ns

src/lib.rs

@@ -62,3 +62,4 @@ pub mod api;
 pub mod client;
 pub mod config;
 mod oauth2;
+pub mod runtime;

src/runtime/mod.rs

@@ -0,0 +1,5 @@
+mod reflector;
+pub use self::reflector::Reflector;
+
+mod informer;
+pub use self::informer::Informer;