From 8a7c3f52039978281c3e1e409848af1c6a4e79bc Mon Sep 17 00:00:00 2001 From: Tamipes Date: Thu, 4 Jun 2026 16:47:29 +0200 Subject: [PATCH] chore: add constant for lables used in kubernetes --- src/kube_cache.rs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/kube_cache.rs b/src/kube_cache.rs index 9b9e671..2ae4641 100644 --- a/src/kube_cache.rs +++ b/src/kube_cache.rs @@ -18,6 +18,8 @@ use crate::{ packets::{clientbound::status::StatusTrait, SendPacket}, OpaqueError, }; +const MAIN_LABEL: &str = "tami.moe/minecraft"; +const PORT_LABEL: &str = "tami.moe/minecraft-port"; /// This is the layer who is respinsible for caching requests. /// @@ -57,12 +59,12 @@ impl KubeCache { } async fn get_deploys(&self) -> ObjectList { // let lp: ListParams = ListParams::default(); - let lp: ListParams = ListParams::default().labels("tami.moe/minecraft"); + let lp: ListParams = ListParams::default().labels(MAIN_LABEL); self.deployments.list(&lp).await.unwrap() } async fn get_srvs(&self) -> ObjectList { // let lp: ListParams = ListParams::default(); - let lp: ListParams = ListParams::default().labels("tami.moe/minecraft"); + let lp: ListParams = ListParams::default().labels(MAIN_LABEL); self.services.list(&lp).await.unwrap() } @@ -453,8 +455,8 @@ where res.labels() .iter() .filter(|(key, value)| match key.as_str() { - "tami.moe/minecraft" => value.as_str() == addr, - "tami.moe/minecraft-port" => { + MAIN_LABEL => value.as_str() == addr, + PORT_LABEL => { found_port = true; value.as_str() == port }