Struct AqlClient 

pub struct AqlClient { /* private fields */ }

AQL client with connection pooling, retry logic, and compression

Implementations

impl AqlClient

pub fn new() -> Self

Create a new client with default configuration

Default configuration uses plaintext (no TLS), so this never fails.

pub fn with_config(config: ClientConfig) -> NetResult<Self>

Create a new client with custom configuration

Errors

Returns NetError::TlsError if TLS configuration is invalid or certificate/key files cannot be read.

pub fn builder() -> AqlClientBuilder

Create a client using a builder pattern

pub fn add_endpoint(&self, id: String, address: String)

Add an endpoint to the client’s connection pool

pub fn add_endpoint_with_weight(&self, id: String, address: String, weight: u32)

Add an endpoint with weight for weighted load balancing

pub fn remove_endpoint(&self, endpoint_id: &str) -> bool

Remove an endpoint from the connection pool

pub async fn get_service_client(&self) -> NetResult<AqlServiceClient<Channel>>

Get a gRPC AQL service client from the connection pool

Applies compression settings if the compression feature is enabled and the compression config is set to a non-identity algorithm.

pub async fn execute_query( &self, request: QueryRequest, ) -> NetResult<QueryResponse>

Execute a single AQL query with retry and circuit breaker protection

pub async fn execute_batch( &self, request: BatchRequest, ) -> NetResult<BatchResponse>

Execute a batch of AQL queries with retry and circuit breaker protection

pub async fn health_check( &self, service: Option<String>, ) -> NetResult<HealthCheckResponse>

Perform a health check against the server

pub async fn execute_with_retry<F, T>(&self, operation: F) -> NetResult<T>

where F: Fn(AqlServiceClient<Channel>) -> Pin<Box<dyn Future<Output = NetResult<T>> + Send>>, T: Send + 'static,

Execute an operation with retry logic, circuit breaker, and exponential backoff

The operation closure receives an AqlServiceClient<Channel> and returns a boxed future resolving to NetResult<T>.

pub fn pool_stats(&self) -> PoolStats

Get connection pool statistics

pub fn circuit_breaker_stats(&self) -> Option<CircuitBreakerStats>

Get circuit breaker statistics

pub fn retry_config(&self) -> &RetryConfig

Get the client’s retry configuration

pub fn compression_config(&self) -> &CompressionConfig

Get the client’s compression configuration

pub fn tls_config(&self) -> Option<&TlsClientConfig>

Get the client’s TLS configuration

pub async fn drain(&self) -> NetResult<()>

Drain the connection pool (prepare for graceful shutdown)

pub async fn shutdown(self) -> NetResult<()>

Shutdown the client gracefully

Trait Implementations

impl Default for AqlClient

fn default() -> Self

Returns the “default value” for a type.