Struct ClientPool 

pub struct ClientPool<T: Transport> { /* private fields */ }

A pool of client connections.

The pool manages connections to multiple MCP servers, reusing existing connections when possible and creating new ones as needed.

Example

use mcpkit_client::{ClientPool, ClientPoolBuilder};
use mcpkit_transport::SpawnedTransport;
use mcpkit_core::error::McpError;

let pool = ClientPool::<SpawnedTransport>::builder()
    .client_info("my-client", "1.0.0")
    .max_connections(5)
    .build();

let client = pool.acquire("server-key", || async {
    // Create a new connection to a server
    // TransportError converts to McpError automatically
    Ok::<_, McpError>(
        SpawnedTransport::spawn("my-server", &[] as &[&str]).await?
    )
}).await?;

// Use the client
let tools = client.list_tools().await?;

// Client is returned to pool when dropped

Implementations

impl<T: Transport + 'static> ClientPool<T>

pub fn builder() -> ClientPoolBuilder

Create a new pool builder.

pub fn new(client_info: ClientInfo, client_caps: ClientCapabilities) -> Self

Create a new pool with default configuration.

pub fn with_config( client_info: ClientInfo, client_caps: ClientCapabilities, config: PoolConfig, ) -> Self

Create a new pool with custom configuration.

pub async fn acquire<F, Fut>( &self, key: impl Into<String>, connect: F, ) -> Result<PooledClient<T>, McpError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<T, McpError>>,

Acquire a connection from the pool.

If a cached connection is available, it is returned. Otherwise, the connect function is called to create a new connection.

Arguments

• key - A unique key identifying the server
• connect - A function that creates a new transport connection

Errors

Returns an error if the connection cannot be acquired.

pub async fn clear(&self)

Clear all cached connections.

pub async fn clear_server(&self, key: &str)

Clear cached connections for a specific server.

pub async fn stats(&self) -> PoolStats

Get statistics about the pool.

Trait Implementations

impl<T: Transport + 'static> Clone for ClientPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.