Struct ToolExecutor 

pub struct ToolExecutor { /* private fields */ }

Tool Executor

Executes tool calls through the transport layer with support for timeout, retry, and proper error handling.

Implementations

impl ToolExecutor

pub fn new(router: Arc<ToolRouter>, registry: Arc<RegistryService>) -> Self

Create a new tool executor

pub fn with_config( router: Arc<ToolRouter>, registry: Arc<RegistryService>, config: ExecutionConfig, ) -> Self

Create with custom configuration

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

Execute a tool call

Routes the call to the appropriate service and executes it with timeout and retry support.

pub async fn execute_with_id( &self, tool_name: &str, params: Value, request_id: JsonRpcId, ) -> Result<Value, ToolExecutorError>

Execute a tool call with a specific request ID

pub async fn register_connection( &self, service_id: ServiceId, _transport: StdioTransport, )

Register a transport connection for a service

pub async fn remove_connection(&self, service_id: &ServiceId)

Remove a transport connection

pub async fn is_connected(&self, service_id: &ServiceId) -> bool

Check if a service is connected

Trait Implementations

impl Debug for ToolExecutor

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

Formats the value using the given formatter.