Struct WASMTransportImpl 

pub struct WASMTransportImpl {
    runtime: Arc<WASMRuntime>,
    memory_manager: Arc<RwLock<MemoryManagerImpl>>,
    bridge: Arc<HostBridgeImpl>,
    modules: Arc<RwLock<HashMap<String, WASMModuleInfo>>>,
    config: TransportConfig,
    connected: Arc<RwLock<bool>>,
    stats: Arc<RwLock<TransportStats>>,
}

WASM transport for direct module communication

Fields

runtime: Arc<WASMRuntime>

WASM runtime

memory_manager: Arc<RwLock<MemoryManagerImpl>>

Memory manager

bridge: Arc<HostBridgeImpl>

Host bridge for communication

modules: Arc<RwLock<HashMap<String, WASMModuleInfo>>>

Loaded modules

config: TransportConfig

Transport configuration

connected: Arc<RwLock<bool>>

Connection state

stats: Arc<RwLock<TransportStats>>

Transport statistics

Implementations

impl WASMTransportImpl

pub fn new( enable_wasi: bool, memory_limit_mb: u64, max_execution_time_ms: u64, ) -> Result<Self>

Create a new WASM transport with default configuration

pub fn with_config( wasm_config: WASMConfig, transport_config: TransportConfig, ) -> Result<Self>

Create a new WASM transport with custom configuration

pub fn runtime(&self) -> &Arc<WASMRuntime>

Get a reference to the WASM runtime

pub fn memory_manager(&self) -> &Arc<RwLock<MemoryManagerImpl>>

Get a reference to the memory manager

pub fn bridge(&self) -> &Arc<HostBridgeImpl>

Get a reference to the host bridge

pub async fn get_modules(&self) -> HashMap<String, WASMModuleInfo>

Get all loaded modules

pub async fn get_wasm_stats(&self) -> WASMStats

Get WASM runtime statistics

pub async fn call_wasm_function( &self, module_id: &str, function_name: &str, args: Vec<Bytes>, ) -> Result<Bytes>

Call a function in a WASM module

Trait Implementations

impl Clone for WASMTransportImpl

fn clone(&self) -> WASMTransportImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WASMTransportImpl

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

Formats the value using the given formatter.

impl TransportStrategy for WASMTransportImpl

type Error = WASMTransportError

Error type for this transport

fn connect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Connect to the transport endpoint

fn send<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Self::Error>> + Send + 'async_trait>>

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

Send a request and receive a response

fn send_no_response<'life0, 'life1, 'async_trait>( &'life0 self, data: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Send data without expecting a response (fire and forget)

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

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

Close the transport connection

fn is_connected(&self) -> bool

Check if the transport is connected

fn transport_type(&self) -> TransportType

Get the transport type identifier