Struct McpEngineClient 

pub struct McpEngineClient { /* private fields */ }

A connected MCP client: initialize done, ready for tools/call.

Implementations

impl McpEngineClient

pub fn connect(spec: &EngineSpec) -> Result<Self>

Connect over the transport spec selects and run the handshake.

pub fn connect_with(spec: &EngineSpec, timeout: Duration) -> Result<Self>

Self::connect with a per-request timeout.

pub fn connect_stdio( command: &str, args: &[String], timeout: Duration, ) -> Result<Self>

Spawn command args… (stderr inherited) and connect over its stdio.

pub fn protocol_version(&self) -> &str

The protocol revision the server answered with.

pub fn server_info(&self) -> &Value

The server’s serverInfo ({ name, version }).

pub fn request(&mut self, method: &str, params: Value) -> Result<Value>

One JSON-RPC request; the result, or the server’s error as Error::Other.

pub fn notify(&mut self, method: &str, params: Value) -> Result<()>

One JSON-RPC notification (no reply).

pub fn list_tools(&mut self) -> Result<Vec<Value>>

tools/list: the catalog as the server describes it.

pub fn call_tool(&mut self, name: &str, args: Value) -> Result<ToolResult>

tools/call: the tool’s JSON body and its error flag. A reply whose text content is not JSON is an error (the reference’s tool <name> returned non-JSON).

pub fn call(&mut self, name: &str, args: Value) -> Result<Value>

Self::call_tool with an error result turned into an error.

pub fn close(&mut self) -> Result<()>

End the session: stdio — stdin EOF, wait, kill after the grace period; HTTP — DELETE with the session id. Idempotent.

Trait Implementations

impl Debug for McpEngineClient

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

Formats the value using the given formatter.

impl Drop for McpEngineClient

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EngineClient for McpEngineClient

fn read_doc(&mut self, path: &str) -> Result<Option<DocBytes>>

docs_read by path; a tool error (doc_missing, …) reads as absent, as the reference treats it. The hash is computed here: the wire carries the bytes, not the store’s file_hash.

fn observe_many(&mut self, files: &[FileBytes]) -> Result<Vec<ObserveOutcome>>

Observe whole-file bytes as observed commits (echo-suppressed engine-side), one batch, then sweep the pool.

fn observe_delete(&mut self, path: &str) -> Result<DeleteOutcome>

Mirror a source-side deletion (tombstone, then sweep).

fn changes_since( &mut self, cursor: i64, limit: Option<usize>, origin: Option<&str>, ) -> Result<ChangesPage>

The repo’s change feed after cursor (§6).

fn close(&mut self) -> Result<()>

Release the connection (the store’s lifetime is the caller’s).