Struct WasmChainAdapter 

pub struct WasmChainAdapter { /* private fields */ }

The per-request WASM dispatch adapter.

Holds the proxy-wasm host’s PluginInstances for the route’s WASM plugins and implements WasmDispatch so the unified crate::plugins::PluginChain can drive them alongside native filters with no dataplane-visible difference in attachment semantics.

Implementations

impl WasmChainAdapter

pub fn new(instances: PluginInstances) -> Self

Wrap a per-request PluginInstances (created by crate::wasm::runner::PluginRunner::instantiate).

pub fn has_pause(&self) -> bool

Whether a plugin is paused for callouts (the driver’s loop condition, DW-167).

pub fn paused_plugin(&self) -> Option<&str>

The paused plugin’s name (failure attribution for the loop guard and callout errors; falls back to the caller’s choice).

pub fn pending_callouts(&mut self) -> Option<(String, Vec<CalloutRequest>)>

Drain the paused plugin’s pending callouts as transport-ready requests (FIFO — the order the plugin dispatched them). None when nothing is paused (the driver’s defensive path).

pub fn requeue_callouts(&mut self, requests: Vec<CalloutRequest>)

Re-enqueue callouts the driver drained but did not perform: a mid-delivery re-dispatch (ChainOutcome::CalloutPending while queued requests remain) must not abandon them — the remainder goes back AHEAD of the new queue, preserving dispatch order, so every dispatched callout is eventually performed (or the loop guard trips). No-op when nothing is paused.

pub fn deliver_callout( &mut self, token: u32, resp: &CalloutResponse, ) -> ChainOutcome

Deliver a completed callout response to the paused plugin (synchronous wasmtime re-entry) and collect its resumed outcome. ChainOutcome::CalloutPending means the plugin dispatched another callout inside the callback — keep driving. On every terminal outcome the pause record is cleared.

pub fn paused_request_headers(&self) -> Vec<(String, String)>

The paused plugin’s resumed request_headers payload (its post-callout header map) — what the chain resumes from.

pub fn paused_response_headers(&self) -> Vec<(String, String)>

The paused plugin’s resumed response_headers payload.

pub fn paused_request_body(&self) -> Vec<u8>

The paused plugin’s resumed request_body payload.

pub fn paused_response_body(&self) -> Vec<u8>

The paused plugin’s resumed response_body payload.

pub fn clear_pause(&mut self)

Clear the pause record after the driver collected the resumed plugin’s phase payload (the record survives the Continue delivery so paused_* can read the payload afterwards).

Trait Implementations

impl WasmDispatch for WasmChainAdapter

fn on_request_headers( &mut self, name: &str, headers: Vec<(String, String)>, ) -> (ChainOutcome, Vec<(String, String)>)

Run on_request_headers for the named WASM plugin. Returns the outcome and the (possibly modified) headers.

fn on_request_body( &mut self, name: &str, body: Vec<u8>, ) -> (ChainOutcome, Vec<u8>)

Run on_request_body for the named WASM plugin. Returns the outcome and the (possibly modified) body.

fn on_response_headers( &mut self, name: &str, headers: Vec<(String, String)>, ) -> (ChainOutcome, Vec<(String, String)>)

Run on_response_headers for the named WASM plugin. Returns the outcome and the (possibly modified) headers.

fn on_response_body( &mut self, name: &str, body: Vec<u8>, ) -> (ChainOutcome, Vec<u8>)

Run on_response_body for the named WASM plugin. Returns the outcome and the (possibly modified) body.

fn on_done(&mut self)

Call on_done for all WASM instances (the cleanup path).