Get instance 👍

Author: EliXorZz

src/epsilon/server/instance_provider.rs

@@ -44,6 +44,13 @@ impl InstanceProvider {
         Ok(self.kube.delete_pod(name).await?)
     }
 
+    pub async fn get_instance(&self, instance_name: &str) -> EResult<Instance> {
+        let pod = self.kube.get_pod(instance_name).await?;
+        let instance = Instance::from_pod(pod);
+
+        Ok(instance)
+    }
+
     pub async fn get_instances(
         &self,
         instance_type: &InstanceType,
@@ -221,3 +228,13 @@ pub async fn get_all(instance_provider: &State<Arc<InstanceProvider>>) -> String
 
     json!({ "instances": json_array }).to_string()
 }
+
+#[rocket::get("/get_from_name/<instance_name>")]
+pub async fn get_from_name(
+    instance_name: &str,
+    instance_provider: &State<Arc<InstanceProvider>>,
+) -> String {
+    let instance = instance_provider.get_instance(instance_name).await.unwrap();
+
+    serde_json::to_string(&instance.to_json().await).unwrap()
+}

src/k8s/kube.rs

@@ -82,6 +82,14 @@ impl Kube {
                             "name": "epsilon-configuration"
                         }
                     }],
+                    "env": [{
+                        "name": "NAME",
+                        "valueFrom": {
+                            "fieldRef": {
+                                "fieldPath": "metadata.name"
+                            }
+                        }
+                    }],
                     "ports": [
                         {
                             "containerPort": port,
@@ -150,6 +158,10 @@ impl Kube {
         Ok(pods.items)
     }
 
+    pub async fn get_pod(&self, pod_name: &str) -> Result<Pod, Error> {
+        Ok(self.pods.get(pod_name).await?)
+    }
+
     pub async fn patch_pod(&self, name: &str, patch: &Value) -> Result<(), Error> {
         let parameters = PatchParams::default();
 

src/main.rs

@@ -100,10 +100,10 @@ async fn main() -> EResult<()> {
             HubTask::init(&epsilon_api, &instance_provider, &queue_provider).await?,
             2000,
         )
-        .ignite_task(
-            CleanTask::init(&epsilon_api, &instance_provider, &queue_provider).await?,
-            10000,
-        )
+        // .ignite_task(
+        //     CleanTask::init(&epsilon_api, &instance_provider, &queue_provider).await?,
+        //     10000,
+        // )
         .ignite_task(
             QueueTask::init(&epsilon_api, &instance_provider, &queue_provider).await?,
             2000,
@@ -131,6 +131,7 @@ async fn main() -> EResult<()> {
                 epsilon::server::instance_provider::in_game,
                 epsilon::server::instance_provider::get,
                 epsilon::server::instance_provider::get_all
+                epsilon::server::instance_provider::get_from_name
             ],
         )
         .launch()