Struct ConnectionManager 

pub struct ConnectionManager { /* private fields */ }

Manages connection limits, request queuing, and shutdown coordination.

Implementations

impl ConnectionManager

pub fn new(config: ConnectionConfig) -> Self

Create a new connection manager with the given configuration.

pub fn try_accept(&self) -> Option<ConnectionGuard>

Try to accept a new connection. Returns a guard that releases the slot on drop. Returns None if the connection limit is reached or server is shutting down.

pub async fn acquire_request_permit(&self) -> Option<OwnedSemaphorePermit>

Get a permit for processing a request. Blocks if at capacity. Returns None if the request times out waiting for a slot.

pub fn idle_timeout(&self) -> Duration

Get the idle timeout duration.

pub fn request_timeout(&self) -> Duration

Get the request timeout duration.

pub fn is_shutting_down(&self) -> bool

Check if the server is shutting down.

pub fn initiate_shutdown(&self)

Initiate graceful shutdown.

pub fn active_connections(&self) -> u64

Get current active connection count.

pub fn rejected_connections(&self) -> u64

Get total rejected connections.

pub fn drain_timeout(&self) -> Duration

Get the drain timeout for graceful shutdown.

pub async fn wait_for_drain(&self)

Wait until all connections are closed or drain timeout expires.