Struct McpQueryAdapter 

pub struct McpQueryAdapter { /* private fields */ }

Server-side ProjectionAdapter backed by an OutputStore (in-flight-safe, subtask-4) with a RunStore-backed result_ref fallback (see the module doc for the full narrative).

Implementations

impl McpQueryAdapter

pub fn new( data_store: Arc<dyn OutputStore>, run_store: Arc<dyn RunStore>, ) -> Self

Builds an adapter reading through data_store (in-flight-safe, tried first) with run_store-backed result_ref fallback.

Trait Implementations

impl ProjectionAdapter for McpQueryAdapter

fn project( &self, key: &ProjectionKey, ctx_data: &Value, ) -> Result<ProjectionRef, ProjectionError>

ctx_data is used only to fail loud up front (mirrors mlua_swarm::core::projection::FileProjectionAdapter::project’s own not-found check) — the returned ProjectionRef::Query locator carries key itself, not a resolved value; the real lookup happens later, at Self::fetch time, against whatever the addressed Run’s backing is then (which may differ from ctx_data, e.g. after a re-kick, or once a step submits through the Data-plane store).

fn name(&self) -> &'static str

Stable adapter name ("file" / "mcp-query"), used in log lines and diagnostics.

fn fetch(&self, key: &ProjectionKey) -> Result<Value, ProjectionError>

Pulls the value addressed by key directly, without going through a previously returned ProjectionRef locator.

fn pointer_line(&self, r: &ProjectionRef) -> String

Renders the 1-3 line pointer this adapter’s ProjectionRef contributes to the directive header. Must never embed the projected value itself (inline full-embed is the exact problem projection exists to avoid — see the module doc).