Struct EmbeddedClient 

pub struct EmbeddedClient { /* private fields */ }

A client that wraps a Kernel directly for in-process access.

Example

use kaish_client::EmbeddedClient;
use kaish_kernel::{Kernel, KernelConfig};

let kernel = Kernel::new(KernelConfig::transient())?;
let client = EmbeddedClient::new(kernel);

let result = client.execute("X=42").await?;
assert!(result.ok());

let value = client.get_var("X").await?;
assert_eq!(value, Some(Value::Int(42)));

Implementations

impl EmbeddedClient

pub fn new(kernel: Kernel) -> Self

Create a new embedded client wrapping the given kernel.

pub fn transient() -> ClientResult<Self>

Create a new embedded client with a transient (non-persistent) kernel.

pub fn with_defaults() -> ClientResult<Self>

Create a new embedded client with default configuration.

pub fn kernel(&self) -> &Kernel

Get a reference to the underlying kernel.

pub async fn execute_streaming( &self, input: &str, on_output: &mut (dyn FnMut(&ExecResult) + Send), ) -> ClientResult<ExecResult>

Execute with a per-statement output callback.

Each statement’s result is passed to on_output as it completes. External commands in interactive mode already stream via Stdio::inherit(); this callback handles builtins and other captured output.

pub async fn execute_with_options( &self, input: &str, opts: ExecuteOptions, ) -> ClientResult<ExecResult>

Execute with full per-call options (timeout, cancel token, vars overlay, cwd override). Use Self::execute_with_options_streaming for the per-statement callback variant.

pub async fn execute_with_options_streaming( &self, input: &str, opts: ExecuteOptions, on_output: &mut (dyn FnMut(&ExecResult) + Send), ) -> ClientResult<ExecResult>

Execute with options + per-statement output callback.

Trait Implementations

impl Clone for EmbeddedClient

fn clone(&self) -> EmbeddedClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl KernelClient for EmbeddedClient

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, input: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<ExecResult>> + 'async_trait>>

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

Execute kaish source code.

fn execute_with_vars<'life0, 'life1, 'async_trait>( &'life0 self, input: &'life1 str, vars: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = ClientResult<ExecResult>> + 'async_trait>>

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

Execute kaish source code with a transient overlay of exported variables.

fn get_var<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<Option<Value>>> + 'async_trait>>

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

Get a variable value.

fn set_var<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, value: Value, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + 'async_trait>>

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

Set a variable value.

fn list_vars<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<Vec<(String, Value)>>> + 'async_trait>>

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

List all variables.

fn tool_schemas<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<Vec<ToolSchema>>> + 'async_trait>>

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

List the schemas of all available tools (builtins + registered tools).

fn has_function<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<bool>> + 'async_trait>>

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

Report whether a user-defined function with the given name exists.

fn cancel<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + 'async_trait>>

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

Cancel the kernel’s in-flight execution.

fn cwd<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<String>> + 'async_trait>>

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

Get the current working directory.

fn set_cwd<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + 'async_trait>>

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

Set the current working directory.

fn last_result<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<ExecResult>> + 'async_trait>>

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

Get the last execution result ($?).

fn reset<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + 'async_trait>>

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

Reset the kernel to initial state.

fn ping<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<String>> + 'async_trait>>

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

Ping the kernel (health check).

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ClientResult<()>> + 'async_trait>>

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

Shutdown the kernel.

fn read_blob<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<Vec<u8>>> + 'async_trait>>

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

Read a blob by ID.

fn write_blob<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, content_type: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = ClientResult<String>> + 'async_trait>>

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

Write a blob and return its ID.

fn delete_blob<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ClientResult<bool>> + 'async_trait>>

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

Delete a blob by ID.