pub struct IOTracker(/* private fields */);Implementations§
Source§impl IOTracker
impl IOTracker
Sourcepub fn incremental_stats(&self) -> IoStats
pub fn incremental_stats(&self) -> IoStats
Get IO statistics and reset the counters (incremental pattern).
This returns the accumulated statistics since the last call and resets the internal counters to zero.
Sourcepub fn stats(&self) -> IoStats
pub fn stats(&self) -> IoStats
Get a snapshot of current IO statistics without resetting counters.
This returns a clone of the current statistics without modifying the internal state. Use this when you need to check stats without resetting.
Sourcepub fn record_read(
&self,
method: &'static str,
path: Path,
num_bytes: u64,
range: Option<Range<u64>>,
)
pub fn record_read( &self, method: &'static str, path: Path, num_bytes: u64, range: Option<Range<u64>>, )
Record a read operation for tracking.
This is used by readers that bypass the ObjectStore layer (like LocalObjectReader) to ensure their IO operations are still tracked.
Sourcepub fn record_write(&self, method: &'static str, path: Path, num_bytes: u64)
pub fn record_write(&self, method: &'static str, path: Path, num_bytes: u64)
Record a write operation for tracking.
This is used by writers that bypass the ObjectStore layer (like LocalWriter) to ensure their IO operations are still tracked.
Trait Implementations§
Source§impl WrappingObjectStore for IOTracker
impl WrappingObjectStore for IOTracker
Source§fn wrap(
&self,
_store_prefix: &str,
target: Arc<dyn ObjectStore>,
) -> Arc<dyn ObjectStore>
fn wrap( &self, _store_prefix: &str, target: Arc<dyn ObjectStore>, ) -> Arc<dyn ObjectStore>
Wrap an object store with additional functionality Read more
Auto Trait Implementations§
impl Freeze for IOTracker
impl RefUnwindSafe for IOTracker
impl Send for IOTracker
impl Sync for IOTracker
impl Unpin for IOTracker
impl UnsafeUnpin for IOTracker
impl UnwindSafe for IOTracker
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreCreates a shared type from an unshared type.