Struct MemoryTracker 

pub struct MemoryTracker { /* private fields */ }

Per-operator memory tracker wrapping a shared MemoryBudget.

Each blocking operator should hold its own MemoryTracker and call try_reserve before buffering data. The tracker records per-operator peak memory so it can later be reported to the ProfileCollector.

Implementations

impl MemoryTracker

pub fn new(budget: MemoryBudget) -> Self

Create a new tracker backed by budget.

pub fn try_reserve(&mut self, bytes: usize) -> Result<(), QueryError>

Reserve bytes additional memory through the shared budget.

Updates the per-operator peak tracker and returns an error when the global budget is exceeded.

pub fn release(&mut self, bytes: usize)

Release bytes from both the global budget and this tracker.

pub fn peak(&self) -> usize

Peak memory observed by this tracker.

pub fn current(&self) -> usize

Current tracked bytes.

pub fn try_reserve_row(&mut self, row: &[Value]) -> Result<(), QueryError>

Convenience: reserve memory for a single row (includes Value deep heap data).

pub fn try_reserve_rows( &mut self, rows: &[Vec<Value>], ) -> Result<(), QueryError>

Convenience: reserve memory for many rows.

pub fn reset(&mut self)

Release all tracked bytes and reset the tracker to zero.

Called by operator close() instead of re-estimating current state.

impl MemoryTracker

pub fn reserve_guarded( &mut self, bytes: usize, ) -> Result<MemoryTrackerReservation<'_>, QueryError>

Reserve bytes through the shared budget and return a scoped reservation guard. Unlike the raw try_reserve the guard automatically releases on drop, protecting against leaks.

Trait Implementations

impl Clone for MemoryTracker

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 MemoryTracker

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

Formats the value using the given formatter.