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 }