Struct NntpProxy 

pub struct NntpProxy { /* private fields */ }

Implementations

impl NntpProxy

pub fn new(config: Config) -> Result<Self>

pub async fn prewarm_connections(&self) -> Result<()>

Prewarm all connection pools before accepting clients Creates all connections concurrently and returns when ready

pub async fn graceful_shutdown(&self)

Gracefully shutdown all connection pools

pub fn servers(&self) -> &[ServerConfig]

Get the list of servers

pub fn router(&self) -> &Arc<BackendSelector>

Get the router

pub fn connection_providers(&self) -> &[DeadpoolConnectionProvider]

Get the connection providers

pub fn buffer_pool(&self) -> &BufferPool

Get the buffer pool

pub async fn handle_client( &self, client_stream: TcpStream, client_addr: SocketAddr, ) -> Result<()>

pub async fn handle_client_per_command_routing( &self, client_stream: TcpStream, client_addr: SocketAddr, ) -> Result<()>

Handle client connection using per-command routing mode

This creates a session with the router, allowing commands from this client to be routed to different backends based on load balancing.

Trait Implementations

impl Clone for NntpProxy

fn clone(&self) -> NntpProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NntpProxy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.