Struct QdrantPool 

pub struct QdrantPool { /* private fields */ }

Connection pool for Qdrant gRPC driver.

Maintains a pool of idle connections and reuses them instead of creating a new TCP+H2 handshake per request. Connections are returned to the idle queue when the PooledConnection is dropped.

Example

use qail_qdrant::{QdrantPool, PoolConfig};

let pool = QdrantPool::new(
    PoolConfig::new("localhost", 6334).max_connections(20)
).await?;

// Get a connection from the pool (reuses idle connections)
let mut conn = pool.get().await?;
let results = conn.search("products", &embedding, 10, None).await?;
// conn is returned to the pool when dropped

Implementations

impl QdrantPool

pub async fn new(config: PoolConfig) -> QdrantResult<Self>

Create a new connection pool.

pub async fn get(&self) -> QdrantResult<PooledConnection>

Get a connection from the pool.

Returns an idle connection if available, otherwise creates a new one. The semaphore limits total connections to max_connections.

pub async fn idle_count(&self) -> usize

Number of idle connections waiting for reuse.

pub fn available(&self) -> usize

Number of available permits (connections not in use).

pub fn max_connections(&self) -> usize

Maximum number of connections.

Trait Implementations

impl Clone for QdrantPool

fn clone(&self) -> QdrantPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.