Struct BytesPool 

pub struct BytesPool { /* private fields */ }

Tiered buffer pool for zero-copy buffer management.

This pool provides 4 tiers of buffers for different size ranges:

• Small: 4KB - 64KB
• Medium: 64KB - 512KB
• Large: 512KB - 4MB
• XLarge: > 4MB

Buffers are automatically reused when returned to the pool.

Example

let pool = BytesPool::new_tiered();

// Acquire a buffer (automatically selects tier based on size)
let mut buffer = pool.acquire_buffer(8192).await;

// Use the buffer...
buffer.put_slice(b"hello world");

// Return to pool (automatic when dropped)
drop(buffer);

// Next acquisition will reuse the buffer
let mut buffer2 = pool.acquire_buffer(8192).await;
assert!(pool.hit_rate() > 0.0); // Buffer was reused!

Implementations

impl BytesPool

pub fn new_tiered() -> Self

Create new tiered pool with default configuration.

Tier Configuration

• Small: 4KB buffers, max 1000 concurrent
• Medium: 64KB buffers, max 500 concurrent
• Large: 512KB buffers, max 100 concurrent
• XLarge: 4MB buffers, max 25 concurrent

Example

let pool = BytesPool::new_tiered();

pub fn with_config(config: BytesPoolConfig) -> Self

Create pool with custom configuration.

Example

let config = BytesPoolConfig {
    small_size: 8 * 1024,  // 8KB small buffers
    small_max: 2000,
    ..Default::default()
};
let pool = BytesPool::with_config(config);

pub async fn acquire_buffer(&self, size: usize) -> PooledBuffer

Acquire buffer with automatic tier selection.

Selects the appropriate tier based on requested size and blocks until a buffer is available. Reuses returned buffers when available.

Arguments

• size - Minimum capacity for the buffer

Returns

A PooledBuffer that releases the permit and returns buffer to pool when dropped.

Example

let mut buffer = pool.acquire_buffer(8192).await;

pub fn try_acquire_buffer(&self, size: usize) -> Option<PooledBuffer>

Try to acquire buffer without blocking.

Arguments

• size - Minimum capacity for the buffer

Returns

• Some(buffer) - If a buffer was available
• None - If the pool is at capacity

Example

if let Some(mut buffer) = pool.try_acquire_buffer(8192) {
    // Use buffer...
}

pub fn metrics(&self) -> &BytesPoolMetrics

Get pool metrics.

pub fn hit_rate(&self) -> f64

Get pool hit rate (0.0 - 1.0).

pub fn available_buffers(&self) -> u64

Get the number of available buffers in the pool.

Trait Implementations

impl Clone for BytesPool

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BytesPool

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

Formats the value using the given formatter.