Struct RemoteFileExecutor 

pub struct RemoteFileExecutor { /* private fields */ }

Implementations

impl RemoteFileExecutor

pub fn new( inner: Arc<dyn ToolExecutor>, host: HostBridge, session_id: String, tools: &[String], ) -> Result<Self>

Trait Implementations

impl ToolExecutor for RemoteFileExecutor

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, _: &'life1 ToolCall, ) -> Pin<Box<dyn Future<Output = Result<ToolResult, ToolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a tool call

fn execute_with_context_outcome<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, call: &'life1 ToolCall, ctx: ToolExecutionContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<ToolOutcome, ToolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Outcome-aware dispatch: returns the tool’s ToolOutcome rather than the collapsed ToolResult, so the agent loop can branch on Completed/Running/NeedsHuman directly instead of sniffing markers on a result. The default collapses via the execute_with_context path (always Completed), so executors that never surface Running/NeedsHuman (composition, MCP, tests) need no override; the built-in + overlay executors override this to return the real outcome.

fn execute_with_context<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, call: &'life1 ToolCall, ctx: ToolExecutionContext<'life2>, ) -> Pin<Box<dyn Future<Output = Result<ToolResult, ToolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Executes a tool call with streaming-capable context.

fn check_permissions_for<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, call: &'life1 ToolCall, ctx: &'life2 ToolExecutionContext<'life3>, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutcome>, ToolError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Permission gate for a tool call, exposed on the executor trait so the check is part of the executor chain.

fn list_tools(&self) -> Vec<ToolSchema>

Lists all available tools and their schemas

fn for_session(&self, _session: &Session) -> Option<Arc<dyn ToolExecutor>>

Optionally bind an already installed Host tool surface to a canonical Session contract. This selects registrations, never adds a grant. Unknown wrappers retain the existing behavior with None.

fn resolve_reference_for_session( &self, session: &Session, reference: &str, ) -> Option<String>

Use the same versioned exact owner for live dispatch and typed replay.

fn execute_exact_with_context_outcome<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, call: &'life1 ToolCall, execution_name: &'life2 str, ctx: ToolExecutionContext<'life3>, ) -> Pin<Box<dyn Future<Output = Result<ToolOutcome, ToolError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

Execute a call through an already-selected exact owner.

fn check_permissions_for_exact<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, call: &'life1 ToolCall, execution_name: &'life2 str, ctx: &'life3 ToolExecutionContext<'life4>, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutcome>, ToolError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, Self: 'async_trait,

Permission gate for an already-selected exact owner identity.

fn check_permissions_for_resolved<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, call: &'life1 ToolCall, execution_name: &'life2 str, args: &'life3 Value, ctx: &'life4 ToolExecutionContext<'life5>, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutcome>, ToolError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, Self: 'async_trait,

Permission gate for a call whose exact execution identity and effective arguments have already been resolved by a wrapping executor.

fn owns_exact_tool(&self, tool_name: &str) -> bool

Returns whether this executor owns tool_name as a complete, exact, case-sensitive execution identity.

fn exact_tool_owner(&self, _name: &str) -> Option<&dyn ToolExecutor>

Read-only observation of the concrete exact owner in a known routing chain. Unknown wrappers return None; existence/name is not provenance.

fn execution_contract_for_exact(&self, name: &str) -> Option<&'static str>

Observe semantics through the existing exact-owner chain. Calling only the owner’s local hook avoids recursion when an owner returns self. Opaque wrappers supply no provenance, even when their catalog has a name.

fn local_execution_contract(&self, _name: &str) -> Option<&'static str>

Only concrete owners override this hook. Transparent wrappers retain their existing exact-owner forwarding instead of guessing provenance.

fn tool_instance_for_exact(&self, name: &str) -> Option<Arc<dyn Tool>>

Registry replacement is observable even if name and contract agree.

fn local_tool_instance(&self, _name: &str) -> Option<Arc<dyn Tool>>

fn framework_session_tool_for_exact( &self, name: &str, ) -> Option<HostFrameworkSessionTool>

Only an explicit Host factory supplies this opaque in-process proof. Unknown wrappers and names/contract strings alone supply no provenance.

fn local_framework_session_tool( &self, _name: &str, ) -> Option<HostFrameworkSessionTool>

fn tool_guidance(&self) -> Option<String>

Server-level usage guidance to surface in the system prompt for whatever this executor currently exposes — e.g. the instructions an MCP server returns from initialize. Because it is derived from the live executor, the text is naturally scoped to what is actually connected/loaded for the run (a disconnected server contributes nothing).

fn tool_mutability(&self, tool_name: &str) -> ToolMutability

Returns mutability metadata for a tool name when available. Executors that can inspect concrete tools should override this.

fn call_mutability(&self, call: &ToolCall) -> ToolMutability

Returns mutability metadata for a specific tool call when available. Defaults to name-based classification.

fn tool_concurrency_safe(&self, tool_name: &str) -> bool

Returns whether a tool can safely execute in parallel with other read-only tools. Executors that can inspect concrete tools should override this. Fallback keeps current behavior for known read-only tools.

fn call_concurrency_safe(&self, call: &ToolCall) -> bool

Returns whether a specific tool call can safely run in parallel. Defaults to the tool-name level classification.

fn call_parallel_classification( &self, call: &ToolCall, ) -> (ToolMutability, bool)

Classify a tool call’s mutability AND concurrency-safety together, returning (mutability, concurrency_safe).