Struct VCLPool 

pub struct VCLPool { /* private fields */ }

Manages multiple VCLConnections under a single pool.

Each connection gets a unique ConnectionId assigned at bind(). The pool enforces a maximum connection limit set at construction.

Implementations

impl VCLPool

pub fn new(max_connections: usize) -> Self

Create a new pool with a maximum number of concurrent connections.

Example

use vcl_protocol::pool::VCLPool;
let pool = VCLPool::new(10);

pub async fn bind(&mut self, addr: &str) -> Result<ConnectionId, VCLError>

Bind a new connection to a local UDP address and add it to the pool.

Returns the ConnectionId assigned to this connection.

Errors

• VCLError::InvalidPacket — pool is at maximum capacity
• VCLError::IoError — socket bind failed

pub async fn connect( &mut self, id: ConnectionId, addr: &str, ) -> Result<(), VCLError>

Connect a pooled connection to a remote peer (client side handshake).

Errors

• VCLError::InvalidPacket — connection ID not found
• VCLError::HandshakeFailed — handshake failed

pub async fn accept_handshake( &mut self, id: ConnectionId, ) -> Result<(), VCLError>

Accept an incoming handshake on a pooled connection (server side).

Errors

• VCLError::InvalidPacket — connection ID not found
• VCLError::HandshakeFailed — handshake failed

pub async fn send( &mut self, id: ConnectionId, data: &[u8], ) -> Result<(), VCLError>

Send data on a pooled connection.

Errors

• VCLError::InvalidPacket — connection ID not found
• Any error from VCLConnection::send

pub async fn recv(&mut self, id: ConnectionId) -> Result<VCLPacket, VCLError>

Receive the next data packet on a pooled connection.

Errors

• VCLError::InvalidPacket — connection ID not found
• Any error from VCLConnection::recv

pub async fn ping(&mut self, id: ConnectionId) -> Result<(), VCLError>

Send a ping on a pooled connection.

Errors

• VCLError::InvalidPacket — connection ID not found
• Any error from VCLConnection::ping

pub async fn rotate_keys(&mut self, id: ConnectionId) -> Result<(), VCLError>

Rotate keys on a pooled connection.

Errors

• VCLError::InvalidPacket — connection ID not found
• Any error from VCLConnection::rotate_keys

pub fn close(&mut self, id: ConnectionId) -> Result<(), VCLError>

Close a specific connection and remove it from the pool.

Errors

• VCLError::InvalidPacket — connection ID not found
• VCLError::ConnectionClosed — already closed

pub fn close_all(&mut self)

Close all connections and clear the pool.

pub fn len(&self) -> usize

Returns the number of active connections in the pool.

pub fn is_empty(&self) -> bool

Returns true if the pool has no active connections.

pub fn is_full(&self) -> bool

Returns true if the pool has reached its maximum capacity.

pub fn connection_ids(&self) -> Vec<ConnectionId>

Returns a list of all active ConnectionIds in the pool.

pub fn contains(&self, id: ConnectionId) -> bool

Returns true if a connection with the given ID exists in the pool.

pub fn get(&self, id: ConnectionId) -> Result<&VCLConnection, VCLError>

Get a reference to a connection by ID.

Errors

Returns VCLError::InvalidPacket if the ID is not found.

Trait Implementations

impl Drop for VCLPool

fn drop(&mut self)

Executes the destructor for this type.