Struct RecyclingMemoryChunkSource 

pub struct RecyclingMemoryChunkSource { /* private fields */ }

In-memory source used to verify real buffer recycling and lease accounting.

The immutable backing cloud represents external source storage. Emitted chunk buffers are separately reserved and returned to the pool on drop.

Implementations

impl RecyclingMemoryChunkSource

pub fn try_new( schema: SchemaDescriptor, cloud: PointCloud, options: StreamOptions, cancellation: CancellationToken, ) -> RecordsResult<Self>

Creates a recycling source over an immutable backing cloud.

pub fn buffer_set_allocations(&self) -> u64

Returns buffer-set allocations performed because the pool was empty.

pub fn pooled_buffer_sets(&self) -> usize

Returns recycled buffer sets currently available to the source.

Trait Implementations

impl BoundedSpatialRecordSource for RecyclingMemoryChunkSource

fn schema(&self) -> &SchemaDescriptor

Schema shared by every emitted record.

fn options(&self) -> &StreamOptions

Validated execution options.

fn memory_tracker(&self) -> &MemoryTracker

Exact tracker shared by emitted chunk leases.

fn cancellation_token(&self) -> CancellationToken

Cooperative cancellation state checked at chunk boundaries.

fn max_chunk_bytes(&self) -> u64

Conservative maximum resident bytes for one emitted chunk.

fn next_chunk(&mut self) -> Option<RecordsResult<SpatialRecordChunk>>

Returns the next leased chunk, or None after an explicit end.