Struct HeapBufferPool 

pub struct HeapBufferPool { /* private fields */ }

Implementations

impl HeapBufferPool

pub fn new( buffer_size: usize, batch_count: usize, batch_size: usize, ) -> HeapBufferPool

Methods from Deref<Target = BufferPool>

pub fn total_buffer_count(&self) -> usize

Get the total number of buffers from this pool that are in circulation.

pub fn buffer_size(&self) -> usize

Get the size in bytes of each buffer in this pool.

pub fn buffer_by_id(&self, id: u32) -> BufferPtr

pub fn register_thread(&self) -> BufferPoolThreadGuard<'_>

Register the current thread as a known user of buffers until the returned guard object is dropped. This is purely an optimization and is optional to do. It prevents an atomic reference count from being unnecessarily incremented and decremented when buffers are received and released by this thread.

pub async fn acquire(&self) -> BufferPtr

pub fn try_acquire(&self) -> Option<BufferPtr>

pub unsafe fn release(&self, buffer: BufferPtr)

Trait Implementations

impl Clone for HeapBufferPool

fn clone(&self) -> HeapBufferPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Deref for HeapBufferPool

type Target = BufferPool

The resulting type after dereferencing.

fn deref(&self) -> &<HeapBufferPool as Deref>::Target

Dereferences the value.

impl Drop for HeapBufferPool

fn drop(&mut self)

Executes the destructor for this type.

impl Send for HeapBufferPool

impl Sync for HeapBufferPool