[WIP] rust

packages/rust/armonik/src/objects/mod.rs

@@ -33,6 +33,7 @@ pub mod sessions;
 pub mod submitter;
 pub mod tasks;
 pub mod versions;
+pub mod worker;
 
 pub use configuration::Configuration;
 pub use count::Count;

packages/rust/armonik/src/objects/worker/health_check.rs

@@ -0,0 +1,44 @@
+use crate::api::v3;
+
+#[derive(Debug, Clone, Default, PartialEq, Eq, PartialOrd, Ord, Hash)]
+pub struct Request {}
+
+super::super::impl_convert!(
+    struct Request = v3::Empty {
+    }
+);
+
+#[derive(Debug, Clone, Default, PartialEq, Eq, PartialOrd, Ord, Hash)]
+pub enum Response {
+    #[default]
+    Unknown = 0,
+    Serving = 1,
+    NotServing = 2,
+}
+
+impl From<i32> for Response {
+    fn from(value: i32) -> Self {
+        match value {
+            0 => Self::Unknown,
+            1 => Self::Serving,
+            2 => Self::NotServing,
+            _ => Self::Unknown,
+        }
+    }
+}
+
+impl From<Response> for v3::worker::HealthCheckReply {
+    fn from(value: Response) -> Self {
+        Self {
+            status: value as i32,
+        }
+    }
+}
+
+impl From<v3::worker::HealthCheckReply> for Response {
+    fn from(value: v3::worker::HealthCheckReply) -> Self {
+        value.status.into()
+    }
+}
+
+super::super::impl_convert!(req Response : v3::worker::HealthCheckReply);

packages/rust/armonik/src/objects/worker/mod.rs

@@ -0,0 +1,2 @@
+pub mod health_check;
+pub mod process;

packages/rust/armonik/src/objects/worker/process.rs

@@ -0,0 +1,15 @@
+use super::super::Output;
+
+use crate::api::v3;
+
+pub struct Response {
+    pub communication_token: String,
+    pub output: Output,
+}
+
+super::super::impl_convert!(
+    struct Response = v3::worker::ProcessReply {
+        communication_token,
+        output = option output,
+    }
+);