Struct TrackedStore 

pub struct TrackedStore<S> { /* private fields */ }

Storage adapter that tracks bytes read from disk.

Wraps an inner storage and accumulates byte counts into shared stats.

Implementations

impl<S> TrackedStore<S>

pub fn new(inner: Arc<S>, stats: SharedIoStats) -> Self

Create a new tracked store wrapping the given storage.

Trait Implementations

impl<S: Debug> Debug for TrackedStore<S>

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

Formats the value using the given formatter.

impl<S: ListableStorageTraits> ListableStorageTraits for TrackedStore<S>

fn list(&self) -> Result<StoreKeys, StorageError>

Retrieve all StoreKeys in the store.

fn list_prefix(&self, prefix: &StorePrefix) -> Result<StoreKeys, StorageError>

Retrieve all StoreKeys with a given StorePrefix.

fn list_dir( &self, prefix: &StorePrefix, ) -> Result<StoreKeysPrefixes, StorageError>

Retrieve all StoreKeys and StorePrefix which are direct children of StorePrefix.

fn size(&self) -> Result<u64, StorageError>

Return the total size in bytes of the storage.

fn size_prefix(&self, prefix: &StorePrefix) -> Result<u64, StorageError>

Return the size in bytes of all keys under prefix.

impl<S: ReadableStorageTraits> ReadableStorageTraits for TrackedStore<S>

fn get(&self, key: &StoreKey) -> Result<MaybeBytes, StorageError>

Retrieve the value (bytes) associated with a given StoreKey.

fn get_partial_many<'a>( &'a self, key: &StoreKey, byte_ranges: ByteRangeIterator<'a>, ) -> Result<MaybeBytesIterator<'a>, StorageError>

Retrieve partial bytes from a list of byte ranges for a store key.

fn size_key(&self, key: &StoreKey) -> Result<Option<u64>, StorageError>

Return the size in bytes of the value at key.

fn supports_get_partial(&self) -> bool

Returns whether this store supports partial reads.

fn get_partial( &self, key: &StoreKey, byte_range: ByteRange, ) -> Result<Option<Bytes>, StorageError>

Retrieve partial bytes from a single byte range for a store key.