Struct PluginInstance 

pub struct PluginInstance { /* private fields */ }

A WASM plugin instance ready for execution.

Implementations

impl PluginInstance

pub fn new( engine: &Engine, module: &CompiledModule, limits: PluginLimits, ) -> Result<Self, WasmError>

Create a new plugin instance from a compiled module.

pub fn new_with_http_client( engine: &Engine, module: &CompiledModule, limits: PluginLimits, http_client: Option<Arc<HttpClient>>, ) -> Result<Self, WasmError>

Create a new plugin instance with an HTTP client for outbound calls.

pub fn new_with_options( engine: &Engine, module: &CompiledModule, limits: PluginLimits, http_client: Option<Arc<HttpClient>>, secrets: Option<SecretsStore>, ) -> Result<Self, WasmError>

Create a new plugin instance with HTTP client and secrets.

pub fn new_with_all_options( engine: &Engine, module: &CompiledModule, limits: PluginLimits, http_client: Option<Arc<HttpClient>>, secrets: Option<SecretsStore>, rate_limiter: Option<RateLimiter>, response_cache: Option<ResponseCache>, nats_publisher: Option<Arc<NatsPublisher>>, kafka_publisher: Option<Arc<KafkaPublisher>>, ) -> Result<Self, WasmError>

Create a new plugin instance with all options including rate limiter and cache.

pub fn name(&self) -> &str

Get the plugin name.

pub fn write_to_memory(&mut self, data: &[u8]) -> Result<i32, WasmError>

Write data to the plugin’s linear memory and return the pointer.

Uses the plugin’s exported alloc function so that dlmalloc is aware of the allocation and will not reuse the region during deserialization. Falls back to growing memory directly for legacy plugins that lack the alloc export (only safe for very small payloads like config JSON).

pub fn init(&mut self, config_json: &[u8]) -> Result<i32, WasmError>

Call the init function with the given config.

pub fn on_request(&mut self, request_json: &[u8]) -> Result<i32, WasmError>

Call on_request with the given request data.

pub fn on_response(&mut self, response_json: &[u8]) -> Result<i32, WasmError>

Call on_response with the given response data.

pub fn dispatch(&mut self, request_json: &[u8]) -> Result<i32, WasmError>

Call dispatch with the given request data.

pub fn take_output(&mut self) -> Vec<u8>

Get the output buffer contents.

pub fn set_context(&mut self, context: RequestContext)

Set the request context for the next call.

pub fn get_context(&self) -> RequestContext

Get the current request context (after modifications by host functions).

pub fn take_last_http_result(&mut self) -> Option<Vec<u8>>

Take the last HTTP result buffer (from host_http_call or host_http_stream).

Returns None if no HTTP call was made or the result was already taken.

pub fn set_stream_sender(&mut self, sender: Arc<UnboundedSender<StreamEvent>>)

Inject a stream sender for host_http_stream before calling dispatch.

The sender is wrapped in an Arc so host functions can clone it for use inside std::thread::scope without lifetime conflicts.

pub fn take_ws_upgrade_request(&mut self) -> Option<WsUpgradeRequest>

Take the upstream WebSocket upgrade request from host_ws_upgrade (ADR-0026).

Returns None if no WebSocket upgrade was requested or the request was already taken.

pub fn set_request_body(&mut self, body: Option<Vec<u8>>)

Set the request/response body for the next handler call (side-channel).

pub fn take_output_body(&mut self) -> Option<Option<Vec<u8>>>

Take the output body set by the plugin via host_body_set/host_body_clear.