Struct ToolExecutor 

pub struct ToolExecutor { /* private fields */ }

Routes tool calls to the appropriate backend.

Implementations

impl ToolExecutor

pub fn new() -> Self

pub fn with_mcp_registry(self, registry: Arc<RwLock<McpToolRegistry>>) -> Self

Set the MCP tool registry for routing MCP tool calls.

pub fn register_builtin( &mut self, name: impl Into<String>, tool: Arc<dyn BuiltinTool>, )

Register a built-in tool.

pub fn register_mcp( &mut self, name: impl Into<String>, server_name: impl Into<String>, )

Register an MCP tool (from a connected server).

pub fn register_wasm( &mut self, name: impl Into<String>, module_name: impl Into<String>, )

Register a WASM tool.

pub async fn execute( &self, tool_name: &str, arguments: Value, ) -> Result<Value, ToolError>

Execute a tool by name.

pub fn tool_names(&self) -> Vec<String>

List all registered tool names.

pub fn get_concurrency_policy( &self, tool_name: &str, ) -> Option<ConcurrencyPolicy>

Get the concurrency policy for a tool by name.

pub fn as_llm_tools(&self) -> Vec<ToolDefinition>

Convert registered tools to LLM-compatible tool definitions.

impl ToolExecutor

Convenience: execute a batch of tool calls concurrently. This is a thin wrapper around ConcurrentToolDispatcher::dispatch.

pub async fn execute_concurrent( self: &Arc<Self>, tool_calls: &[ToolCall], policy_lookup: impl Fn(&str) -> ConcurrencyPolicy, ) -> Vec<ToolResult>

Trait Implementations

impl Default for ToolExecutor

fn default() -> Self

Returns the “default value” for a type.