commit a2e0f5a3782cd1c8d92f9b3db506d504f103e88c
from: murilo ijanc <murilo@ijanc.org>
date: Sun Dec  7 14:11:36 2025 UTC

Pass kube client to cluster state

commit - 598795a38a048f5c012dfc15ab16bde96dda701a
commit + a2e0f5a3782cd1c8d92f9b3db506d504f103e88c
blob - 703cb1bbc8e690fc0ab88fcf9818739d2de86453
blob + 182b3cbd5c4a80b87d3d291fceb4e7acb55f81e9
--- kopsd/src/kube_worker.rs
+++ kopsd/src/kube_worker.rs
@@ -14,8 +14,6 @@
 // OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 //
 
-// kopsd/src/kube_worker.rs
-
 use std::sync::Arc;
 
 use anyhow::Result;
@@ -39,11 +37,12 @@ use crate::state::{ClusterName, ClusterState};
 /// Initialize a ClusterState for a given cluster config and start
 /// a background reflector task to keep the Store<Pod> up-to-date.
 pub async fn init_cluster_state(
-    cfg: ClusterConfig,
+    cluster_name: ClusterName,
+    client: Client,
 ) -> Result<Arc<ClusterState>> {
-    let cluster_name: ClusterName = cfg.name.clone();
+    // let cluster_name: ClusterName = cfg.name.clone();
 
-    let client = build_client_for_cluster(&cfg).await?;
+    // let client = build_client_for_cluster(&cfg).await?;
 
     let pods_api: Api<Pod> = Api::all(client);