Struct StorageQuotaManager 

pub struct StorageQuotaManager { /* private fields */ }

Thread-safe manager that tracks per-namespace storage quotas.

Example

use ipfrs_storage::quota_manager::{StorageQuotaManager, QuotaPolicy};

let mgr = StorageQuotaManager::new(0.8);
mgr.register_namespace("ns1".to_owned(), 1024, QuotaPolicy::HardLimit).unwrap();
mgr.check_write("ns1", 512).unwrap();
mgr.record_write("ns1", 512).unwrap();
let stats = mgr.stats("ns1").unwrap();
assert_eq!(stats.used_bytes, 512);

Implementations

impl StorageQuotaManager

pub fn new(soft_threshold: f64) -> Self

Create a new StorageQuotaManager.

soft_threshold is a ratio in [0.0, 1.0] — namespaces whose usage exceeds this fraction of their limit are considered “over threshold”. The recommended default is 0.8 (80 %).

pub fn register_namespace( &self, namespace: String, limit_bytes: u64, policy: QuotaPolicy, ) -> Result<(), QuotaError>

Register a new namespace with the given limit and policy.

Returns QuotaError::InvalidLimit if limit_bytes is 0 and the policy is not QuotaPolicy::NoLimit.

pub fn check_write( &self, namespace: &str, size_bytes: u64, ) -> Result<(), QuotaError>

Check whether a write of size_bytes is permitted for namespace.

• QuotaPolicy::HardLimit: returns Err(QuotaExceeded) when used + size > limit.
• QuotaPolicy::SoftLimit: logs a warning when the limit would be exceeded, but still returns Ok(()).
• QuotaPolicy::NoLimit: always returns Ok(()).

Returns QuotaError::NamespaceNotFound for unknown namespaces.

pub fn record_write( &self, namespace: &str, size_bytes: u64, ) -> Result<(), QuotaError>

Record that size_bytes have been successfully written to namespace.

Atomically increments used_bytes and block_count.

pub fn record_delete(&self, namespace: &str, size_bytes: u64)

Record that size_bytes have been deleted from namespace.

Uses saturating subtraction so that underflow is safe. block_count is also decremented using saturating subtraction.

pub fn stats(&self, namespace: &str) -> Result<QuotaStats, QuotaError>

Return a snapshot of quota statistics for namespace.

pub fn all_stats(&self) -> Vec<QuotaStats>

Return snapshots for all registered namespaces, sorted by namespace name.

pub fn namespaces_over_threshold(&self) -> Vec<String>

Return namespaces whose usage ratio exceeds self.soft_threshold.

pub fn reset_namespace(&self, namespace: &str) -> Result<(), QuotaError>

Zero out used_bytes and block_count for namespace.

pub fn remove_namespace(&self, namespace: &str) -> bool

Remove namespace from the manager.

Returns true if the namespace existed, false otherwise.