Struct PluginInstance 

pub struct PluginInstance { /* private fields */ }

A per-request plugin instance: a wasmtime store + instance.

Implementations

impl PluginInstance

pub fn on_request_headers( &mut self, headers: Vec<(String, String)>, ) -> PhaseResult

Call proxy_on_request_headers(context_id, num_headers, end_of_stream). Sets the request headers in the context before calling.

pub fn on_request_body(&mut self, body: Vec<u8>) -> PhaseResult

Call proxy_on_request_body(context_id, body_size, end_of_stream). Sets the request body in the context before calling.

pub fn on_response_headers( &mut self, headers: Vec<(String, String)>, ) -> PhaseResult

Call proxy_on_response_headers(context_id, num_headers, end_of_stream). Sets the response headers in the context before calling.

pub fn on_response_body(&mut self, body: Vec<u8>) -> PhaseResult

Call proxy_on_response_body(context_id, body_size, end_of_stream). Sets the response body in the context before calling.

pub fn request_headers(&self) -> &[(String, String)]

Get the (possibly modified) request headers from the context.

pub fn response_headers(&self) -> &[(String, String)]

Get the (possibly modified) response headers from the context.

pub fn request_body(&self) -> &[u8]

Get the (possibly modified) request body from the context.

pub fn response_body(&self) -> &[u8]

Get the (possibly modified) response body from the context.

pub fn logs(&self) -> &[(u32, String)]

Get the logs emitted by the plugin.

pub fn memory_bytes(&mut self, offset: usize, len: usize) -> Option<Vec<u8>>

Read len bytes of the plugin’s linear memory at offset (test support: asserting a callback’s in-memory side effects).

pub fn shared_data_snapshot(&self) -> SharedData

A snapshot of the VM-scoped shared-data map (test support: the cross-instance store DW-167 introduced).

pub fn take_pending_callouts(&mut self) -> Vec<PendingCallout>

Drain the callouts registered since the last phase/callback invocation (DW-167). The dispatch driver performs them in FIFO order (one round each).

pub fn requeue_callouts(&mut self, pending: Vec<PendingCallout>)

Re-enqueue callouts the dispatch driver drained but did NOT perform (DW-167): when the first of several queued deliveries re-dispatches from its callback, the un-performed remainder goes back AHEAD of the newly registered queue — preserving the global dispatch order and guaranteeing every dispatched callout is eventually performed (or the loop guard trips).

pub fn deliver_callout_response( &mut self, token: u32, resp: &CalloutResponse, ) -> PhaseResult

Deliver a completed callout response and collect the plugin’s resumed outcome (DW-167): the response’s headers (:status first, hop-by-hop stripped) and body land in the context’s callout-response stores, then the host calls proxy_on_http_call_response(context_id, token, num_headers, body_size, num_trailers) — the 5-parameter shape the Rust SDK 0.2.5 exports (its first parameter is the ABI’s context slot, which the SDK ignores; it routes by token inside the module). The export returns nothing in the SDK: the plugin’s decision is expressed through what it does inside the callback (send_http_response, header mutations, another dispatch, or nothing = resume Continue). A module without the export resumes Continue (nothing to tell).

pub fn on_done(&mut self)

Call proxy_on_done and proxy_on_log (the cleanup path). The SDK’s proxy_on_done returns a bool while the WAT fixtures return nothing — the result is ignored either way, so both shapes are accepted.