Struct ClientSessionBuilder 

pub struct ClientSessionBuilder { /* private fields */ }

Builder for constructing ClientSession instances

Provides a fluent API for creating client sessions with different routing modes.

Examples

use std::net::SocketAddr;
use std::sync::Arc;
use nntp_proxy::session::ClientSession;
use nntp_proxy::pool::BufferPool;
use nntp_proxy::router::BackendSelector;
use nntp_proxy::config::RoutingMode;
use nntp_proxy::types::BufferSize;
use nntp_proxy::auth::AuthHandler;
use nntp_proxy::metrics::MetricsCollector;

let addr: SocketAddr = "127.0.0.1:8080".parse().unwrap();
let buffer_pool = BufferPool::new(BufferSize::try_new(8192).unwrap(), 10);
let auth_handler = Arc::new(AuthHandler::new(None, None).unwrap());
let metrics = MetricsCollector::new(1);

// Stateful 1:1 routing mode
let session = ClientSession::builder(addr.into(), buffer_pool.clone(), auth_handler.clone(), metrics.clone())
    .build();

// Per-command routing mode
let router = Arc::new(BackendSelector::new());
let session = ClientSession::builder(addr.into(), buffer_pool.clone(), auth_handler, metrics)
    .with_router(router)
    .with_routing_mode(RoutingMode::PerCommand)
    .build();

Implementations

impl ClientSessionBuilder

pub fn with_router(self, router: Arc<BackendSelector>) -> Self

Configure the session to use per-command routing with a backend router

When a router is provided, the session will route each command independently to potentially different backend servers.

pub const fn with_routing_mode(self, mode: RoutingMode) -> Self

Set the routing mode for this session

Arguments

• mode - The routing mode (Stateful, PerCommand, or Hybrid)

Note: If you use with_router(), you typically want PerCommand or Hybrid mode.

pub fn with_auth_handler(self, auth_handler: Arc<AuthHandler>) -> Self

Set the authentication handler

pub fn with_connection_stats( self, connection_stats: ConnectionStatsAggregator, ) -> Self

Add connection stats aggregation to this session

pub fn with_cache(self, cache: Arc<UnifiedCache>) -> Self

Add article cache to this session (always present for backend availability tracking)

pub const fn with_cache_articles(self, cache: bool) -> Self

Set whether to cache article bodies.

When false, only backend availability is tracked (saves memory). When true, full article bodies are cached.

pub const fn with_adaptive_precheck(self, enable: bool) -> Self

Configure adaptive availability prechecking

pub fn build(self) -> ClientSession

Build the client session

Creates a new ClientSession with a unique client ID and the configured routing mode.