Bump operator-rs to 0.41.0 (#80)

# Description Co-authored-by: Malte Sander <malte.sander.it@gmail.com>
stackabletech · May 25, 2023 · 5730ac9 · 5730ac9
1 parent ffb0ff5
commit 5730ac9
Show file tree

Hide file tree

Showing 4 changed files with 73 additions and 35 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -9,7 +9,12 @@ All notable changes to this project will be documented in this file.
 - Generate OLM bundle for Release 23.4.0 ([#74]).
 - Provide automatic migration 23.1 -> 23.4 ([#77]).
 
+### Changed
+
+- `operator-rs` `0.27.1` -> `0.41.0` ([#80]).
+
 [#74]: https://github.com/stackabletech/listener-operator/pull/74
+[#80]: https://github.com/stackabletech/listener-operator/pull/80
 
 ## [23.4.0] - 2023-04-17
 

diff --git a/Cargo.lock b/Cargo.lock
diff --git a/rust/operator-binary/Cargo.toml b/rust/operator-binary/Cargo.toml
@@ -18,14 +18,14 @@ libc = "0.2.125"
 pin-project = "1.0.10"
 prost = "0.10.3"
 socket2 = { version = "0.4.4", features = ["all"] }
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.27.1" }
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.41.0" }
 tokio = { version = "1.18.2", features = ["full"] }
 tokio-stream = { version = "0.1.8", features = ["net"] }
 tonic = "0.7.2"
 tonic-reflection = "0.4.0"
 anyhow = "1.0.57"
 serde = "1.0.137"
-snafu = "0.7.1"
+snafu = "0.7.4"
 strum = "0.24.1"
 csi-grpc = { path = "../csi-grpc" }
 

diff --git a/rust/operator-binary/src/listener_controller.rs b/rust/operator-binary/src/listener_controller.rs
@@ -9,8 +9,8 @@ use stackable_operator::{
     },
     k8s_openapi::api::core::v1::{Endpoints, Node, Service, ServicePort, ServiceSpec},
     kube::{
-        api::{DynamicObject, ListParams, ObjectMeta},
-        runtime::{controller, reflector::ObjectRef},
+        api::{DynamicObject, ObjectMeta},
+        runtime::{controller, reflector::ObjectRef, watcher},
     },
     logging::controller::{report_controller_reconciled, ReconcilerError},
 };
@@ -24,13 +24,13 @@ const FIELD_MANAGER_SCOPE: &str = "listener";
 
 pub async fn run(client: stackable_operator::client::Client) {
     let controller =
-        controller::Controller::new(client.get_all_api::<Listener>(), ListParams::default());
+        controller::Controller::new(client.get_all_api::<Listener>(), watcher::Config::default());
     let listener_store = controller.store();
     controller
-        .owns(client.get_all_api::<Service>(), ListParams::default())
+        .owns(client.get_all_api::<Service>(), watcher::Config::default())
         .watches(
             client.get_all_api::<Endpoints>(),
-            ListParams::default(),
+            watcher::Config::default(),
             move |endpoints| {
                 listener_store
                     .state()