blink-sdk 0.2.0

Rust SDK for Blink agent sandboxes — BoxLite VM execution, sessions, and V-Hub
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use std::path::{Path, PathBuf};

use anyhow::Result;
use boxlite::SnapshotInfo;

pub use crate::context::{BlinkContext, SessionInfo};

/// Open (create or reuse) a named persistent agent session.
pub async fn open_session(name: &str, image: &str) -> Result<(String, bool)> {
    BlinkContext::new()?.open_session(name, image, false).await
}

pub async fn open_warm_session(name: &str, image: &str) -> Result<(String, bool)> {
    BlinkContext::new()?.open_session(name, image, true).await
}

pub async fn run_in_session(name: &str, script_path: &Path) -> Result<crate::AgentResult> {
    BlinkContext::new()?.run_in_session(name, script_path).await
}

pub async fn spawn_in_session(name: &str, spec: crate::SpawnSpec) -> Result<crate::Execution> {
    BlinkContext::new()?.spawn_in_session(name, spec).await
}

pub async fn checkpoint_session(name: &str, snapshot: &str) -> Result<SnapshotInfo> {
    BlinkContext::new()?.checkpoint_session(name, snapshot).await
}

pub async fn restore_session(name: &str, snapshot: &str) -> Result<()> {
    BlinkContext::new()?.restore_session(name, snapshot).await
}

pub async fn list_checkpoints(name: &str) -> Result<Vec<SnapshotInfo>> {
    BlinkContext::new()?.list_checkpoints(name).await
}

pub async fn list_sessions() -> Result<Vec<SessionInfo>> {
    BlinkContext::new()?.list_sessions().await
}

pub async fn stop_session(name: &str) -> Result<()> {
    BlinkContext::new()?.stop_session(name).await
}

pub async fn remove_session(name: &str, force: bool) -> Result<()> {
    BlinkContext::new()?.remove_session(name, force).await
}

pub async fn export_session(name: &str) -> Result<PathBuf> {
    BlinkContext::new()?.export_session(name).await
}

pub async fn import_session(archive_path: &Path, name: Option<&str>) -> Result<String> {
    BlinkContext::new()?.import_session(archive_path, name).await
}