durable-actors 0.9.1

Standalone regional durable-actors control plane, host, and durability runtime
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::{collections::HashMap, sync::Arc, time::Duration};

use anyhow::{Context, Result, ensure};
use async_trait::async_trait;

use super::{
    remote::{RemoteSandboxProvider, SandboxCluster},
    secrets::SecretResolver,
    *,
};

mod kubernetes;
pub(crate) use super::remote::validate_image;
pub(crate) use kubernetes::GkeConfig;

pub(crate) async fn provider(
    config: GkeConfig,
    secrets: Arc<dyn SecretResolver>,
    connections: connections::HostConnections,
) -> Result<RemoteSandboxProvider> {
    let cluster = kubernetes::Kubernetes::new(kube::Client::try_default().await?, config);
    RemoteSandboxProvider::new("gke", Arc::new(cluster), secrets, connections)
}