Struct LocalProcessRuntime 

pub struct LocalProcessRuntime { /* private fields */ }

Runtime that runs agents as local processes — no Docker or containers needed.

Implementations

impl LocalProcessRuntime

pub fn new(base_workdir: Option<String>, max_processes: Option<u32>) -> Self

Trait Implementations

impl SandboxRuntime for LocalProcessRuntime

fn create_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 SandboxSpec, ) -> Pin<Box<dyn Future<Output = CiabResult<SandboxInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a new sandbox from the given spec.

fn get_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<SandboxInfo>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get info about a sandbox by ID.

fn list_sandboxes<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: Option<SandboxState>, provider: Option<&'life1 str>, labels: &'life2 HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = CiabResult<Vec<SandboxInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List all sandboxes, optionally filtered by state, provider, and labels.

fn start_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Start a sandbox.

fn stop_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Stop a sandbox.

fn pause_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Pause a sandbox.

fn resume_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Resume a paused sandbox.

fn terminate_sandbox<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Terminate and remove a sandbox.

fn exec<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 Uuid, request: &'life2 ExecRequest, ) -> Pin<Box<dyn Future<Output = CiabResult<ExecResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a command inside a sandbox.

fn exec_streaming<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 Uuid, request: &'life2 ExecRequest, ) -> Pin<Box<dyn Future<Output = CiabResult<(Receiver<String>, JoinHandle<CiabResult<ExecResult>>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a command inside a sandbox, streaming stdout lines as they arrive. Returns a receiver of output lines and a join handle for the final ExecResult.

fn exec_streaming_interactive<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 Uuid, request: &'life2 ExecRequest, ) -> Pin<Box<dyn Future<Output = CiabResult<(Receiver<String>, Sender<String>, JoinHandle<CiabResult<ExecResult>>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute a command with bidirectional streaming. Returns (stdout lines receiver, stdin sender, join handle). Send lines to the stdin sender to write to the process’s stdin.

fn read_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 Uuid, path: &'life2 str, ) -> Pin<Box<dyn Future<Output = CiabResult<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Read a file from a sandbox.

fn write_file<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, id: &'life1 Uuid, path: &'life2 str, content: &'life3 [u8], ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Write a file to a sandbox.

fn list_files<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 Uuid, path: &'life2 str, ) -> Pin<Box<dyn Future<Output = CiabResult<Vec<FileInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List files in a directory inside a sandbox.

fn get_stats<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<ResourceStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get resource stats for a sandbox.

fn stream_logs<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _id: &'life1 Uuid, _options: &'life2 LogOptions, ) -> Pin<Box<dyn Future<Output = CiabResult<Receiver<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Stream logs from a sandbox.

fn kill_exec<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = CiabResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Kill an active exec process for a sandbox.