Struct MemoryManager 

pub struct MemoryManager<M: MemoryMetrics> {
    quota: MemoryQuotaState<M>,
}

Generic memory manager for quota-controlled operations.

Fields

quota: MemoryQuotaState<M>

Implementations

impl<M: MemoryMetrics> MemoryManager<M>

pub fn new(limit_bytes: u64, metrics: M) -> Self

Creates a new memory manager with the given limit in bytes. limit_bytes = 0 disables the limit.

pub fn with_granularity( limit_bytes: u64, granularity: PermitGranularity, metrics: M, ) -> Self

Creates a new memory manager with specified granularity.

pub fn limit_bytes(&self) -> u64

Returns the configured limit in bytes (0 if unlimited).

pub fn used_bytes(&self) -> u64

Returns currently used bytes.

pub fn available_bytes(&self) -> u64

Returns available bytes.

Unlimited managers report u64::MAX.

pub async fn acquire(&self, bytes: u64) -> Result<MemoryGuard<M>>

Acquires memory, waiting if necessary until enough is available.

Errors

• Returns error if requested bytes exceed the total limit
• Returns error if the semaphore is unexpectedly closed

pub fn try_acquire(&self, bytes: u64) -> Option<MemoryGuard<M>>

Tries to acquire memory. Returns Some(guard) on success, None if insufficient.

pub async fn acquire_with_policy( &self, bytes: u64, policy: OnExhaustedPolicy, ) -> Result<MemoryGuard<M>>

Acquires memory based on the given policy.

• For OnExhaustedPolicy::Wait: Waits up to the timeout duration for memory to become available
• For OnExhaustedPolicy::Fail: Returns immediately if memory is not available

Errors

• MemoryLimitExceeded: Requested bytes exceed the total limit (both policies), or memory is currently exhausted (Fail policy only)
• MemoryAcquireTimeout: Timeout elapsed while waiting for memory (Wait policy only)
• MemorySemaphoreClosed: The internal semaphore is unexpectedly closed (rare, indicates system issue)

Trait Implementations

impl<M: Clone + MemoryMetrics> Clone for MemoryManager<M>

fn clone(&self) -> MemoryManager<M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<M: MemoryMetrics + Default> Default for MemoryManager<M>

fn default() -> Self

Returns the “default value” for a type.