Method register

vmm/src/discovery.rs:59–97

Register a new VMM instance. Creates the discovery directory if needed and writes the instance info JSON file.

(
        listen_address: &str,
        config_file: Option<&str>,
        image_path: &Path,
        run_path: &Path,
        node_name: &str,
        version: &str,
    )

    /// Register a new VMM instance. Creates the discovery directory if needed
    /// and writes the instance info JSON file.
    pub fn register(
        listen_address: &str,
        config_file: Option<&str>,
        image_path: &Path,
        run_path: &Path,
        node_name: &str,
        version: &str,
    ) -> Result<Self> {
        let dir = discovery_dir();
        fs_err::create_dir_all(&dir).context("failed to create discovery directory")?;

        let id = Uuid::new_v4().to_string();
        let path = dir.join(format!("{id}.json"));

        let cwd = std::env::current_dir().context("failed to get current directory")?;

        let info = VmmInstanceInfo {
            id: id.clone(),
            pid: std::process::id(),
            address: listen_address.to_string(),
            working_dir: cwd.to_string_lossy().to_string(),
            config_file: config_file.map(|s| s.to_string()),
            image_path: image_path.to_string_lossy().to_string(),
            run_path: run_path.to_string_lossy().to_string(),
            node_name: node_name.to_string(),
            version: version.to_string(),
            started_at: std::time::SystemTime::now()
                .duration_since(std::time::UNIX_EPOCH)
                .unwrap_or_default()
                .as_secs(),
        };

        let json =
            serde_json::to_string_pretty(&info).context("failed to serialize instance info")?;
        fs_err::write(&path, &json).context("failed to write discovery file")?;

        info!("registered VMM instance {id} at {}", path.display());
        Ok(Self { path })
    }
}

impl Drop for DiscoveryRegistration {