Method from_driver

crates/openshell-server/src/compute/mod.rs:285–327

(
        driver_name: String,
        driver: SharedComputeDriver,
        shutdown_cleanup: Option<Arc<dyn ShutdownCleanup>>,
        startup_resume: Option<Arc<dyn StartupResume>>,
        driver_p

impl ComputeRuntime {
    #[allow(clippy::too_many_arguments)]
    async fn from_driver(
        driver_name: String,
        driver: SharedComputeDriver,
        shutdown_cleanup: Option<Arc<dyn ShutdownCleanup>>,
        startup_resume: Option<Arc<dyn StartupResume>>,
        driver_process: Option<Arc<ManagedDriverProcess>>,
        store: Arc<Store>,
        sandbox_index: SandboxIndex,
        sandbox_watch_bus: SandboxWatchBus,
        tracing_log_bus: TracingLogBus,
        supervisor_sessions: Arc<SupervisorSessionRegistry>,
        gateway_bind_addresses: Vec<SocketAddr>,
    ) -> Result<Self, ComputeError> {
        let capabilities = driver
            .get_capabilities(Request::new(GetCapabilitiesRequest {}))
            .await
            .map_err(compute_error_from_status)?
            .into_inner();
        let driver_kind = driver_name.parse::<ComputeDriverKind>().ok();
        info!(
            configured_driver = %driver_name,
            advertised_driver = %capabilities.driver_name,
            in_tree = driver_kind.is_some(),
            "Compute driver connected"
        );
        let default_image = capabilities.default_image;
        Ok(Self {
            driver,
            driver_name,
            shutdown_cleanup,
            startup_resume,
            _driver_process: driver_process,
            default_image,
            store,
            sandbox_index,
            sandbox_watch_bus,
            tracing_log_bus,
            supervisor_sessions,
            sync_lock: Arc::new(Mutex::new(())),
            gateway_bind_addresses,
            replica_id: lease::replica_id(),
        })
    }

    /// Serializes sandbox/provider-profile invariant checks and object writes
    /// within this gateway process.