Struct StorageTracker 

pub struct StorageTracker { /* private fields */ }

Real-time storage statistics tracker.

Maintains in-memory counters that are updated on every write operation. Thread-safe via RwLock for concurrent access.

Implementations

impl StorageTracker

pub fn total_stats(&self) -> TierStats

Get total storage stats across all tiers.

pub fn stats_by_type(&self, tier: Tier) -> HashMap<KeyKind, StorageStats>

Get stats aggregated by KeyKind for a specific tier.

pub fn stats_by_type_all_tiers(&self) -> HashMap<KeyKind, TierStats>

Get stats aggregated by KeyKind across all tiers.

pub fn stats_for_object(&self, object_id: ObjectId) -> Option<TierStats>

Get stats for a specific object across all tiers.

pub fn objects_by_tier(&self, tier: Tier) -> Vec<(ObjectId, StorageStats)>

Get all objects for a specific tier, sorted by total bytes descending.

pub fn top_objects_by_size(&self, n: usize) -> Vec<(ObjectId, TierStats)>

Get top N objects by total storage consumption across all tiers.

pub fn config(&self) -> StorageTrackerConfig

Get configuration.

impl StorageTracker

pub fn new(config: StorageTrackerConfig) -> StorageTracker

Create a new storage tracker with the given configuration.

pub fn with_defaults() -> StorageTracker

Create a new tracker with default configuration.

pub fn record_write( &self, tier: Tier, key: &[u8], key_bytes: u64, value_bytes: u64, pre_version: Option<PreVersionInfo>, )

Record a write operation (insert or update).

• tier: Which storage tier this write goes to
• key: The encoded key bytes (unversioned, used for KeyKind lookup)
• key_bytes: Size of the key as stored (typically versioned key size)
• value_bytes: Size of the value being written
• pre_version: Information about the previous version, if the key already existed

pub fn record_delete( &self, tier: Tier, key: &[u8], key_bytes: u64, pre_version: Option<PreVersionInfo>, )

Record a delete operation (tombstone).

• tier: Which storage tier this delete goes to
• key: The encoded key bytes (unversioned, used for KeyKind lookup)
• key_bytes: Size of the tombstone key as stored (typically versioned key size)
• pre_version: Information about the previous version being deleted

pub fn record_drop( &self, tier: Tier, key: &[u8], versioned_key_bytes: u64, value_bytes: u64, )

Record a drop operation (physical removal of historical version entry).

Unlike delete, drop doesn’t create tombstones - it physically removes entries from storage. Used for MVCC cleanup of old versions.

• tier: Which storage tier the drop occurred in
• key: The original (unversioned) encoded key bytes
• versioned_key_bytes: Size of the versioned key being dropped
• value_bytes: Size of the value being dropped

pub fn record_cdc_for_change( &self, tier: Tier, key: &[u8], value_bytes: u64, count: u64, )

Record CDC bytes for a specific change.

Called for each change in a CDC entry to attribute bytes to the source object.

• tier: Which storage tier the CDC entry was written to
• key: The change key (identifies the source object)
• value_bytes: Bytes attributed to this change (distributed overhead)
• count: Number of CDC entries to record (typically 1)

pub fn record_tier_migration( &self, from_tier: Tier, to_tier: Tier, key: &[u8], value_bytes: u64, is_current: bool, )

Record data migration between tiers.

When data moves from one tier to another (e.g., hot -> warm), this updates the stats for both tiers.

pub fn should_checkpoint(&self) -> bool

Check if a checkpoint is needed based on elapsed time.

pub async fn checkpoint_async<S>(&self, storage: &S) -> Result<(), Error>

where S: PrimitiveStorage,

Persist current stats to storage.

Writes all tracked stats to the storage using KeyKind::StorageTracker keys.

pub async fn restore_async<S>( storage: &S, config: StorageTrackerConfig, ) -> Result<StorageTracker, Error>

where S: PrimitiveStorage,

Restore stats from storage on startup.

Loads previously persisted stats from storage using KeyKind::StorageTracker keys.

Trait Implementations

impl Clone for StorageTracker

fn clone(&self) -> StorageTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StorageTracker

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

Formats the value using the given formatter.