Struct WasmEngine 

pub struct WasmEngine { /* private fields */ }

WASM-accessible VPL engine.

Create with new WasmEngine(), load VPL via load(), process events via processEvent() or processBatch(), and receive output events as JSON.

Implementations

impl WasmEngine

pub fn new() -> Self

Create a new engine instance.

pub fn load(&mut self, vpl: &str) -> String

Load a VPL program. Returns JSON: { ok, streams, error? }.

Replaces any previously loaded program. Call this before processing events.

pub fn process_event(&mut self, event_json: &str) -> String

Process a single event (JSON object). Returns JSON: { ok, outputs, error? }.

The event JSON must include an event_type field matching a declared event type. Additional fields are the event data.

{"event_type": "Sensor", "temperature": 150, "zone": "A"}

pub fn process_batch(&mut self, events_json: &str) -> String

Process a batch of events (JSON array of objects). Returns JSON: { ok, outputs, error? }.

pub fn get_topology(&self) -> String

Get the pipeline topology as a JSON graph.

pub fn get_streams(&self) -> String

Get loaded stream names as a JSON array.

pub fn set_trace(&mut self, enabled: bool)

Enable or disable trace mode.

pub fn drain_trace(&mut self) -> String

Drain trace entries as a JSON array.

pub fn validate(&self, vpl: &str) -> String

Validate VPL syntax without loading. Returns JSON: { ok, error? }.

pub fn is_loaded(&self) -> bool

Check if a program is loaded.

Trait Implementations

impl Debug for WasmEngine

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

Formats the value using the given formatter.

impl Default for WasmEngine

fn default() -> Self

Returns the “default value” for a type.

impl From<WasmEngine> for JsValue

fn from(value: WasmEngine) -> Self

Converts to this type from the input type.

impl FromWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type that this converts from when coming back out from the ABI boundary.

unsafe fn from_abi(js: u32) -> Self

Recover a Self from Self::Abi.

impl IntoWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type that this converts into when crossing the ABI boundary.

fn into_abi(self) -> u32

Convert self into Self::Abi so that it can be sent across the wasm ABI boundary.

impl LongRefFromWasmAbi for WasmEngine

type Abi = u32

Same as RefFromWasmAbi::Abi

type Anchor = RcRef<WasmEngine>

Same as RefFromWasmAbi::Anchor

unsafe fn long_ref_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl OptionFromWasmAbi for WasmEngine

fn is_none(abi: &Self::Abi) -> bool

Tests whether the argument is a “none” instance. If so it will be deserialized as None, and otherwise it will be passed to FromWasmAbi.

impl OptionIntoWasmAbi for WasmEngine

fn none() -> Self::Abi

Returns an ABI instance indicating “none”, which JS will interpret as the None branch of this option.

impl RefFromWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type references to Self are recovered from.

type Anchor = RcRef<WasmEngine>

The type that holds the reference to Self for the duration of the invocation of the function that has an &Self parameter. This is required to ensure that the lifetimes don’t persist beyond one function call, and so that they remain anonymous.

unsafe fn ref_from_abi(js: Self::Abi) -> Self::Anchor

Recover a Self::Anchor from Self::Abi.

impl RefMutFromWasmAbi for WasmEngine

type Abi = u32

Same as RefFromWasmAbi::Abi

type Anchor = RcRefMut<WasmEngine>

Same as RefFromWasmAbi::Anchor

unsafe fn ref_mut_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl TryFromJsValue for WasmEngine

fn try_from_js_value(value: JsValue) -> Result<Self, JsValue>

Performs the conversion.

fn try_from_js_value_ref(value: &JsValue) -> Option<Self>

Performs the conversion.

impl VectorFromWasmAbi for WasmEngine

type Abi = <Box<[JsValue]> as FromWasmAbi>::Abi

unsafe fn vector_from_abi(js: Self::Abi) -> Box<[WasmEngine]>

impl VectorIntoWasmAbi for WasmEngine

type Abi = <Box<[JsValue]> as IntoWasmAbi>::Abi

fn vector_into_abi(vector: Box<[WasmEngine]>) -> Self::Abi

impl WasmDescribe for WasmEngine

fn describe()

impl WasmDescribeVector for WasmEngine

fn describe_vector()

impl SupportsConstructor for WasmEngine

impl SupportsInstanceProperty for WasmEngine

impl SupportsStaticProperty for WasmEngine