Struct WasmHostState 

pub struct WasmHostState {
    pub table: ResourceTable,
    pub wasi: WasiCtx,
    pub properties: HashMap<String, Value>,
    pub registry: Arc<Mutex<Registry>>,
    pub call_depth: Arc<AtomicUsize>,
    pub limits: StoreLimits,
    pub state_store: StateStore,
    pub capabilities: WasmCapabilities,
}

Fields

table: ResourceTable

wasi: WasiCtx

properties: HashMap<String, Value>

registry: Arc<Mutex<Registry>>

call_depth: Arc<AtomicUsize>

limits: StoreLimits

state_store: StateStore

capabilities: WasmCapabilities

Trait Implementations

impl Host for WasmHostState

impl Host for WasmHostState

impl Host for WasmHostState

impl HostWithStore<WasmHostState> for HasSelf<WasmHostState>

async fn camel_call( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, payload: String, ) -> Result<String, WasmError>

Invoke any Camel endpoint asynchronously. Returns the response body as a string (JSON-encoded for structured data). TODO(WIT-009): Only string payloads are supported; binary/bytes support is deferred.

async fn camel_poll( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, timeout_ms: u32, ) -> Result<String, WasmError>

Poll an endpoint for a message asynchronously (pull model). Returns the body as a string, or an error on timeout/failure.

fn get_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Option<String>

Read a property from the host Exchange.

fn set_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, )

Write a property to the host Exchange.

fn host_store( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, ) -> Result<(), WasmError>

Store a value that persists across process() calls for this route endpoint. State is scoped per endpoint — different routes using the same plugin get independent state stores.

fn host_load( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Result<Option<String>, WasmError>

Load a previously stored value. Returns none if the key has not been stored.

impl HostWithStore<WasmHostState> for HasSelf<WasmHostState>

async fn camel_call( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, payload: String, ) -> Result<String, WasmError>

Invoke any Camel endpoint asynchronously. Returns the response body as a string (JSON-encoded for structured data). TODO(WIT-009): Only string payloads are supported; binary/bytes support is deferred.

async fn camel_poll( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, timeout_ms: u32, ) -> Result<String, WasmError>

Poll an endpoint for a message asynchronously (pull model). Returns the body as a string, or an error on timeout/failure.

fn get_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Option<String>

Read a property from the host Exchange.

fn set_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, )

Write a property to the host Exchange.

fn host_store( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, ) -> Result<(), WasmError>

Store a value that persists across process() calls for this route endpoint. State is scoped per endpoint — different routes using the same plugin get independent state stores.

fn host_load( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Result<Option<String>, WasmError>

Load a previously stored value. Returns none if the key has not been stored.

impl HostWithStore<WasmHostState> for HasSelf<WasmHostState>

async fn camel_call( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, payload: String, ) -> Result<String, WasmError>

Invoke any Camel endpoint asynchronously. Returns the response body as a string (JSON-encoded for structured data). TODO(WIT-009): Only string payloads are supported; binary/bytes support is deferred.

async fn camel_poll( store: &Accessor<WasmHostState, HasSelf<WasmHostState>>, uri: String, timeout_ms: u32, ) -> Result<String, WasmError>

Poll an endpoint for a message asynchronously (pull model). Returns the body as a string, or an error on timeout/failure.

fn get_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Option<String>

Read a property from the host Exchange.

fn set_property( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, )

Write a property to the host Exchange.

fn host_store( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, value: String, ) -> Result<(), WasmError>

Store a value that persists across process() calls for this route endpoint. State is scoped per endpoint — different routes using the same plugin get independent state stores.

fn host_load( store: Access<'_, WasmHostState, HasSelf<WasmHostState>>, key: String, ) -> Result<Option<String>, WasmError>

Load a previously stored value. Returns none if the key has not been stored.

impl WasiView for WasmHostState

fn ctx(&mut self) -> WasiCtxView<'_>

Yields mutable access to the WasiCtx configuration used for this context.