Struct WasmExecutor 

pub struct WasmExecutor { /* private fields */ }

Executes .wasm32-wasi capability binaries via Wasmtime.

Every invocation creates a fresh Wasmtime Store — no state leaks between calls.

Implementations

impl WasmExecutor

pub fn new() -> Result<Self, ExecutorError>

Create a new WasmExecutor with a default Wasmtime engine.

Errors

Returns ExecutorError::RuntimeSetupFailed if Wasmtime cannot initialise.

pub fn with_limits(limits: WasmExecutionLimits) -> Result<Self, ExecutorError>

Create a WasmExecutor with explicit per-invocation resource limits.

Errors

Returns ExecutorError::RuntimeSetupFailed if Wasmtime cannot initialise.

pub fn with_limits_and_cache_config( limits: WasmExecutionLimits, cache_config: WasmModuleCacheConfig, ) -> Result<Self, ExecutorError>

Create a WasmExecutor with explicit resource limits and module cache bounds.

Errors

Returns ExecutorError::RuntimeSetupFailed if Wasmtime cannot initialise.

pub fn module_cache_stats(&self) -> WasmModuleCacheStats

Return current compiled-module cache counters.

pub fn binary_cache_stats(&self) -> WasmBinaryCacheStats

Return current on-disk binary cache counters.

impl WasmExecutor

pub fn run_bytes( &self, wasm_bytes: &[u8], input: &Value, ) -> Result<Value, ExecutorError>

Execute pre-loaded WASM bytes with the given input.

Exposed separately so tests can pass raw bytes without needing a file on disk. The capability is treated as Stateless with no declared emits — it cannot call traverse_host::emit_event. Use run_bytes_with_capability to exercise the event-emit host function.

Errors

Returns ExecutorError if input serialization fails, the WASM module cannot be compiled or linked, execution fails, or stdout is not valid JSON.

pub fn run_bytes_with_host_abi( &self, wasm_bytes: &[u8], input: &Value, abi_version: &str, ) -> Result<Value, ExecutorError>

Execute pre-loaded WASM bytes with an explicit Traverse Host ABI version.

Errors

Returns ExecutorError if ABI validation fails or execution cannot complete.

pub fn run_bytes_with_capability( &self, wasm_bytes: &[u8], input: &Value, capability_id: &str, emits: &[EventReference], service_type: ServiceType, ) -> Result<ExecutorOutput, ExecutorError>

Execute pre-loaded WASM bytes as a specific capability, exercising traverse_host::emit_event validation against emits/service_type exactly as CapabilityExecutor::execute does.

Errors

Returns ExecutorError if ABI validation fails or execution cannot complete.

pub fn run_bytes_with_mediated_connectors( &self, wasm_bytes: &[u8], input: &Value, capability_id: &str, connector_context: MediatedConnectorContext, ) -> Result<ExecutorOutput, ExecutorError>

Execute bytes with host-owned, activated connector bindings. This is the only API that can enable connector_invoke; callers that do not supply this context retain the deny-by-default handler.

Errors

Returns ExecutorError when the module, guest memory, or execution cannot be completed safely.

Trait Implementations

impl CapabilityExecutor for WasmExecutor

fn execute( &self, capability: &ExecutorCapability, input: &Value, ) -> Result<ExecutorOutput, ExecutorError>

Execute capability with input, returning the output or an error.

impl Debug for WasmExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.