feat(worker/args): add basic command-line args parser

README.md

@@ -0,0 +1,19 @@
+# Tucano
+
+An educational service scheduler and load balancer.
+
+_(WIP - improve README.)_
+
+## Running locally
+
+Controller:
+
+```
+cargo run -p ctl
+```
+
+Worker:
+
+```
+cargo run -p worker -- --controller-addr '127.0.0.1:3000'
+```

worker/Cargo.toml

@@ -7,6 +7,7 @@ edition.workspace = true
 workspace = true
 
 [dependencies]
+clap.workspace = true
 eyre.workspace = true
 proto.workspace = true
 sysinfo.workspace = true

worker/src/args.rs

@@ -0,0 +1,41 @@
+use std::{net::SocketAddr, time::Duration};
+
+use clap::{value_parser, Parser};
+
+pub struct WorkerArgs {
+    /// Controller's address.
+    pub controller_addr: SocketAddr,
+
+    /// Interval at which metrics are pushed to the controller.
+    pub metrics_report_interval: Duration,
+}
+
+impl WorkerArgs {
+    /// Parses the process arguments and returns a new [`Args`].
+    ///
+    /// Panics if missing arguments or if arguments are invalid.
+    pub fn parse() -> Self {
+        let raw = RawWorkerArgs::parse();
+        WorkerArgs {
+            controller_addr: raw.controller_addr,
+            metrics_report_interval: Duration::from_secs(raw.metrics_report_interval.into()),
+        }
+    }
+}
+
+#[derive(Parser)]
+struct RawWorkerArgs {
+    /// Controller's HTTP address.
+    #[arg(short, long)]
+    controller_addr: SocketAddr,
+
+    /// Interval at which metrics are pushed to the controller.
+    ///
+    /// Time in seconds. Must be greater than 1.
+    #[arg(
+        long,
+        default_value = "5",
+        value_parser = value_parser!(u32).range(1..)
+    )]
+    metrics_report_interval: u32,
+}

worker/src/main.rs

@@ -1,20 +1,19 @@
 use eyre::Result;
-use tokio::time::{sleep, Duration};
+use tokio::time::sleep;
 
-use crate::monitor::collector::MetricsCollector;
+use crate::{args::WorkerArgs, monitor::collector::MetricsCollector};
 
-pub mod monitor;
-
-/// `clap` crate report interval placeholder
-/// The value 500 is for quick visualization purposes.
-const REPORT_INTERVAL_IN_MILLIS: u64 = 500;
+mod args;
+mod monitor;
 
 #[tokio::main]
 async fn main() -> Result<()> {
+    let args = WorkerArgs::parse();
+
     let mut metrics_report: MetricsCollector = MetricsCollector::new();
 
     loop {
-        sleep(Duration::from_millis(REPORT_INTERVAL_IN_MILLIS)).await;
+        sleep(args.metrics_report_interval).await;
         let metrics = metrics_report.get_metrics();
         println!("{metrics:#?}");
     }