Fixed build errors

divinerapier · Feb 26, 2020 · 127da76 · 127da76
1 parent 54f06cd
commit 127da76
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 8 deletions.
diff --git a/examples/event_informer.rs b/examples/event_informer.rs
@@ -16,7 +16,7 @@ async fn main() -> anyhow::Result<()> {
     let client = APIClient::new(config);
 
     let events = Api::v1Event(client);
-    let ei = Informer::new(events).init().await?;
+    let ei = Informer::new(events);
 
     loop {
         let mut events = ei.poll().await?.boxed();

diff --git a/examples/node_informer.rs b/examples/node_informer.rs
@@ -20,10 +20,8 @@ async fn main() -> anyhow::Result<()> {
 
     let nodes = RawApi::v1Node();
     let events = Api::v1Event(client.clone());
-    let ni = Informer::raw(client.clone(), nodes)
+    let ni = Informer::raw(client.clone(), nodes);
         //.labels("beta.kubernetes.io/os=linux")
-        .init()
-        .await?;
 
     loop {
         let mut nodes = ni.poll().await?.boxed();

diff --git a/examples/pod_informer.rs b/examples/pod_informer.rs
@@ -19,7 +19,7 @@ async fn main() -> anyhow::Result<()> {
     let namespace = env::var("NAMESPACE").unwrap_or("default".into());
 
     let resource = Api::v1Pod(client.clone()).within(&namespace);
-    let inf = Informer::new(resource.clone()).init().await?;
+    let inf = Informer::new(resource.clone());
 
     loop {
         let mut pods = inf.poll().await?.boxed();

diff --git a/src/runtime/informer.rs b/src/runtime/informer.rs
@@ -1,7 +1,7 @@
 use crate::{
     api::{
-        resource::{KubeObject, ObjectList, WatchEvent},
-        Api, ListParams, NotUsed, RawApi,
+        resource::{KubeObject, WatchEvent},
+        Api, ListParams, RawApi,
     },
     client::APIClient,
     Result,
@@ -142,7 +142,7 @@ where
                 Delay::new(dur).await;
                 // If we are outside history, start over from latest
                 if *needs_resync {
-                    self.reset().await?;
+                    self.reset().await;
                 }
                 *needs_resync = false;
                 *needs_retry = false;