Struct CustomToolProtocol 

pub struct CustomToolProtocol { /* private fields */ }

Custom function-calling tool adapter

This adapter allows you to register Rust functions as tools that agents can use. It’s useful for quick prototyping and simple tool implementations.

Example

use cloudllm::tool_protocols::CustomToolProtocol;
use cloudllm::tool_protocol::{ToolResult, ToolMetadata, ToolParameter, ToolParameterType};
use std::sync::Arc;

let mut adapter = CustomToolProtocol::new();

// Register a synchronous tool
adapter.register_tool(
    ToolMetadata::new("add", "Adds two numbers")
        .with_parameter(
            ToolParameter::new("a", ToolParameterType::Number).required()
        )
        .with_parameter(
            ToolParameter::new("b", ToolParameterType::Number).required()
        ),
    Arc::new(|params| {
        let a = params["a"].as_f64().unwrap_or(0.0);
        let b = params["b"].as_f64().unwrap_or(0.0);
        Ok(ToolResult::success(serde_json::json!({"result": a + b})))
    })
);

Implementations

impl CustomToolProtocol

pub fn new() -> Self

Create an empty adapter ready to accept new tool registrations.

pub async fn register_tool( &self, metadata: ToolMetadata, function: ToolFunction, )

Register a synchronous tool function.

Subsequent calls will overwrite any existing tool with the same name.

pub async fn register_async_tool( &self, metadata: ToolMetadata, function: AsyncToolFunction, )

Register an asynchronous tool function.

pub async fn unregister_tool(&self, name: &str)

Remove a tool from the adapter.

Trait Implementations

impl Default for CustomToolProtocol

fn default() -> Self

Returns the “default value” for a type.

impl ToolProtocol for CustomToolProtocol

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, tool_name: &'life1 str, parameters: JsonValue, ) -> Pin<Box<dyn Future<Output = Result<ToolResult, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Execute a tool with the given parameters

fn list_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ToolMetadata>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Get metadata about available tools

fn get_tool_metadata<'life0, 'life1, 'async_trait>( &'life0 self, tool_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ToolMetadata, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Get metadata about a specific tool

fn protocol_name(&self) -> &str

Protocol identifier (e.g., “mcp”, “custom”, “openai-functions”)

fn initialize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Initialize/connect to the tool protocol

fn shutdown<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Cleanup/disconnect from the tool protocol

fn list_resources<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ResourceMetadata>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

List available resources (MCP Resource support)

fn read_resource<'life0, 'life1, 'async_trait>( &'life0 self, uri: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Read the content of a resource by URI (MCP Resource support)

fn supports_resources(&self) -> bool

Check if this protocol supports resources