Struct AqlServerBuilder 

pub struct AqlServerBuilder<S: StorageEngine> { /* private fields */ }

Server builder for creating AQL service instances.

Configuration is layered via fluent setters. Defaults match AqlServiceImpl::new(storage) exactly; nothing is spawned until Self::build runs.

Implementations

impl<S: StorageEngine + Send + Sync + 'static> AqlServerBuilder<S>

pub fn new(storage: Arc<S>) -> Self

Create a new server builder with the given storage engine.

pub fn with_logging(self, verbosity: LogVerbosity) -> Self

Configure request/response logging verbosity.

Returns self for chaining. The stored verbosity can be retrieved via Self::logging_verbosity so callers can apply a LoggingLayer around the tonic service.

pub fn logging_verbosity(&self) -> Option<LogVerbosity>

Return the configured logging verbosity (if any).

pub fn with_slow_threshold_ms(self, ms: u64) -> Self

Configure the slow-request threshold (ms) for the LoggingLayer.

pub fn slow_threshold_ms(&self) -> Option<u64>

Return the configured slow-request threshold (if any).

pub fn with_bind_addr(self, addr: SocketAddr) -> Self

Set the gRPC server bind address. Recorded for callers that wire a tonic Server::bind; this builder does not itself spawn a tonic server.

pub fn bind_addr(&self) -> Option<SocketAddr>

Return the configured gRPC bind address (if any).

pub fn with_rate_limit_qps(self, qps: f64) -> Self

Configure the steady-state QPS for the rate limiter. Recorded for callers that wire a crate::rate_limiter::RateLimiter.

pub fn rate_limit_qps(&self) -> Option<f64>

Return the configured rate-limit QPS (if any).

pub fn with_jwt_secret_path(self, path: PathBuf) -> Self

Configure the JWT secret path used by the bearer-token auth middleware.

pub fn jwt_secret_path(&self) -> Option<&Path>

Return the configured JWT secret path (if any).

pub fn with_tls_creds(self, creds: &TlsCredsRef<'_>) -> NetResult<Self>

Install initial TLS credentials for live cert rotation.

Builds a rustls::ServerConfig from creds, wraps it in an arc_swap::ArcSwap, and stores the handle on the builder. Callers retrieve the store via Self::tls_config_store and pass it to a crate::tls_acceptor::LiveTlsAcceptor so each new TLS handshake reads the latest cert.

Errors

Returns crate::error::NetError::TlsError if the credentials cannot be parsed into a rustls::ServerConfig.

pub fn tls_config_store(&self) -> Option<Arc<ArcSwap<ServerConfig>>>

Return a clone of the current TLS config store (if installed).

Callers feed this into crate::tls_acceptor::LiveTlsAcceptor::new to enable per-connection cert pickup; the same store can later be updated atomically via store.store(Arc::new(new_config)).

pub fn with_metrics_addr(self, addr: SocketAddr) -> Self

Set the SocketAddr on which the Prometheus metrics HTTP server will listen. When set, Self::build spawns a background task serving GET /metrics.

The metrics server runs on a separate port from gRPC so that scrape traffic never reaches the tonic transport.

pub fn metrics_addr(&self) -> Option<SocketAddr>

Return the configured metrics HTTP address (if any).

pub fn metrics(&self) -> Arc<NetMetrics>

Return a clone of the shared crate::metrics_layer::NetMetrics registry.

Use this to apply crate::metrics_layer::MetricsLayer around the tonic service so that gRPC request metrics flow into the same registry that the HTTP endpoint serves.

pub fn build(self) -> AqlServiceImpl<S>

Build the service implementation.

If Self::with_metrics_addr was called, also spawns the Prometheus HTTP server as a background tokio task. The returned handle is discarded here; the task runs until the process exits or the tokio runtime shuts down.

pub fn build_grpc_service(self) -> AqlServiceServer<AqlGrpcService<S>>

Build a tonic-ready gRPC service (wrapped in AqlServiceServer).

When the compression feature is enabled the server is configured to accept and send gzip-compressed messages.