Struct ResourceBudget 

pub struct ResourceBudget { /* private fields */ }

Shared, allocation-before-ownership resource budget.

Implementations

impl ResourceBudget

pub fn from_options(options: StreamOptions) -> Self

Create a budget from public bounded-execution options.

pub fn new(memory_limit_bytes: u64, max_in_flight_batches: NonZeroUsize) -> Self

Create a budget with a byte limit and a positive in-flight batch limit.

pub fn reserve( &self, scope: ResourceScope, bytes: u64, ) -> Result<ResourceReservation>

Reserve byte ownership before allocating or retaining data.

pub fn reserve_batch( &self, scope: ResourceScope, bytes: u64, ) -> Result<ResourceReservation>

Reserve ownership for one decoded or retained batch before publishing it.

pub const fn memory_limit_bytes(&self) -> u64

Return the configured byte limit.

pub const fn max_in_flight_batches(&self) -> usize

Return the configured pipeline-owned batch limit.

pub fn usage(&self) -> ResourceUsage

Obtain an accounting snapshot for tests, diagnostics, and stream status.

Trait Implementations

impl Clone for ResourceBudget

fn clone(&self) -> ResourceBudget

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResourceBudget

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

Formats the value using the given formatter.