Struct TensorWasmEngine 

pub struct TensorWasmEngine { /* private fields */ }

A configured wasmtime::Engine plus the background epoch ticker that drives interruption.

Implementations

impl TensorWasmEngine

pub const EPOCH_TICK: Duration = DEFAULT_EPOCH_TICK

Default epoch tick interval.

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

Construct an engine with default configuration.

pub fn with_config(cfg: EngineConfig) -> Result<Self, Error>

Construct an engine with explicit configuration.

pub fn inner(&self) -> &Engine

Borrow the underlying wasmtime Engine. Cheap (it’s Arc-shaped internally).

pub fn config(&self) -> &EngineConfig

Borrow the engine config used at construction.

pub fn spawn_epoch_ticker(&mut self)

Spawn a background Tokio task that periodically increments the engine epoch counter. Must be called from inside a Tokio runtime.

Idempotent: if a ticker is already running this is a no-op.

pub fn stop_epoch_ticker(&mut self)

Stop the epoch ticker if one is running.

pub fn is_epoch_ticker_running(&self) -> bool

True if spawn_epoch_ticker has been called on this engine and the ticker has not been stop_epoch_ticker’d.

Used by TensorWasmExecutor to emit a one-shot operator warning the first time an instance is spawned on an engine whose ticker is not running (deadlines are otherwise silently inert).

pub fn tick(&self)

Increment the epoch once manually. Useful for tests that do not want to wait for the background ticker.

Trait Implementations

impl Default for TensorWasmEngine

fn default() -> Self

Returns the “default value” for a type.

impl Drop for TensorWasmEngine

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.