commit - 598795a38a048f5c012dfc15ab16bde96dda701a
commit + a2e0f5a3782cd1c8d92f9b3db506d504f103e88c
blob - 703cb1bbc8e690fc0ab88fcf9818739d2de86453
blob + 182b3cbd5c4a80b87d3d291fceb4e7acb55f81e9
--- kopsd/src/kube_worker.rs
+++ kopsd/src/kube_worker.rs
// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
//
-// kopsd/src/kube_worker.rs
-
use std::sync::Arc;
use anyhow::Result;
/// 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);