monitor: list runner volumes

Author: delan

list-runner-volumes.sh

@@ -0,0 +1,6 @@
+#!/usr/bin/env zsh
+# usage: list-runner-vms.sh
+script_dir=${0:a:h}
+. "$script_dir/common.sh"
+
+zfs list -Ho name -rt volume $SERVO_CI_ZFS_PREFIX

monitor/src/main.rs

@@ -40,6 +40,7 @@ fn main() -> eyre::Result<()> {
 
     dbg!(list_registered_runners_for_host()?);
     dbg!(list_runner_guests()?);
+    dbg!(list_runner_volumes()?);
 
     Ok(())
 }
@@ -87,3 +88,25 @@ fn list_runner_guests() -> eyre::Result<Vec<String>> {
 
     Ok(result.collect())
 }
+
+fn list_runner_volumes() -> eyre::Result<Vec<String>> {
+    let output = Command::new("../list-runner-volumes.sh")
+        .stdout(Stdio::piped())
+        .spawn()
+        .unwrap()
+        .wait_with_output()
+        .unwrap();
+    if !output.status.success() {
+        eyre::bail!("Command exited with status {}", output.status);
+    }
+
+    // Output is already filtered by prefix, but filter again just in case.
+    let prefix = format!("{}/", env::var("SERVO_CI_ZFS_PREFIX")?);
+    let result = str::from_utf8(&output.stdout)
+        .wrap_err("Failed to decode UTF-8")?
+        .split_terminator('\n')
+        .filter(|name| name.starts_with(&prefix))
+        .map(str::to_owned);
+
+    Ok(result.collect())
+}