feat(worker): add runner component

Cargo.toml

@@ -21,6 +21,7 @@ chrono = { version = "0.4", default-features = false, features = [
     "serde",
 ] }
 eyre = "0.6"
+get-port = "4.0.0"
 reqwest = { version = "0.12", features = ["json"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"

proto/src/worker/runner.rs

@@ -3,28 +3,28 @@
 //! service on a given worker node.
 
 use serde::{Deserialize, Serialize};
+use uuid::Uuid;
 
-use crate::common::service::{ServiceName, ServiceSpec};
+/// Specification of a service's instance
+#[derive(Debug, Serialize, Deserialize)]
+pub struct InstanceSpec {
+    id: Uuid,
+    image: String,
+}
 
 /// Starts a **single** deploy of the given service spec.
 ///
 /// The worker server doesn't follow the concurrency limit for the service as
-/// defined in [`ServiceSpec`].
-#[derive(Debug, Serialize, Deserialize)]
-pub struct DeployReq {
-    pub service_spec: ServiceSpec,
-}
-
-/// Response for [`DeployReq`].
+/// defined in [`InstanceSpec`].
 #[derive(Debug, Serialize, Deserialize)]
-pub struct DeployRes {
-    // ???
+pub struct DeployInstanceReq {
+    pub instances: Vec<InstanceSpec>,
 }
 
-/// Stops a given service from running in the system.
+/// Stops a given instance from running in the system.
 #[derive(Debug, Serialize, Deserialize)]
 pub struct StopReq {
-    pub service_name: ServiceName,
+    pub instance: InstanceSpec,
     /// Whether to completely remove the service from the node, calling the
     /// teardown script, if any.
     pub remove: bool,

worker/Cargo.toml

@@ -12,6 +12,7 @@ proto.workspace = true
 
 clap.workspace = true
 eyre.workspace = true
+get-port.workspace = true
 reqwest.workspace = true
 sysinfo.workspace = true
 tokio.workspace = true

worker/src/main.rs

@@ -7,6 +7,7 @@ use crate::{args::WorkerArgs, monitor::pusher};
 
 mod args;
 mod monitor;
+mod runner;
 
 #[tokio::main]
 async fn main() -> Result<()> {

worker/src/runner/builder.rs

@@ -0,0 +1 @@
+

worker/src/runner/mod.rs

@@ -0,0 +1,24 @@
+use std::collections::HashMap;
+
+use proto::worker::runner;
+
+use get_port::{tcp::TcpPort, Range};
+
+pub struct UsedPorts {
+    pub in_use: HashMap<uuid::Uuid,
+}
+
+pub fn deploy(instanceReq: &runner::DeployInstanceReq) -> Result<()> {
+    let tcp_port = TcpPort::in_range(
+        "127.0.0.1",
+        Range {
+            min: 6000,
+            max: 7000,
+        },
+    )
+    .unwrap();
+
+    Ok(())
+}
+
+pub fn terminate(instance: &InstanceSpec) {}