Struct QdrantPool 

pub struct QdrantPool { /* private fields */ }

Connection pool for Qdrant gRPC driver.

Uses a semaphore to limit concurrent connections. Each connection is independent and can be used concurrently.

Example

use qail_qdrant::{QdrantPool, PoolConfig};

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

// Get a connection from the pool
let mut conn = pool.get().await?;
let results = conn.search("products", &embedding, 10, None).await?;

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.

This acquires a permit from the semaphore, limiting concurrency. The connection is created lazily when acquired.

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.