Struct OffloadTelemetry 

pub struct OffloadTelemetry { /* private fields */ }

Mutable, single-threaded offload telemetry collector.

Updates use saturating arithmetic for monotonic counters and durations. Resident bytes are set explicitly, and setting a new value updates the corresponding peak. Wrap this value in a mutex if multiple threads need to record into one collector.

Implementations

impl OffloadTelemetry

pub fn from_plan(plan: &OffloadPlan) -> Self

Creates a collector initialized with a validated plan’s byte totals.

pub fn set_planned_bytes(&mut self, planned_bytes: TierByteTotals)

Replaces the planned byte totals recorded by this collector.

pub fn set_resident_bytes(&mut self, tier: MemoryTier, bytes: u64)

Sets current resident bytes and updates the peak for tier.

pub fn set_resident_units(&mut self, tier: MemoryTier, units: usize)

Sets current resident units and updates the peak for tier.

pub fn record_transfer( &mut self, direction: TransferDirection, bytes: u64, duration: Duration, )

Records one completed transfer using saturating counter updates.

pub fn record_prefetch(&mut self, outcome: PrefetchOutcome)

Records one completed prefetch request and its outcome.

pub fn record_tier_prefetch( &mut self, tier: MemoryTier, outcome: PrefetchOutcome, )

Records a cache request both globally and for its target tier.

pub fn record_prefetch_stall(&mut self, duration: Duration)

Records a demand stall while waiting for a prefetched unit.

pub fn record_eviction(&mut self, bytes: u64)

Records one eviction using saturating counter updates.

pub fn record_tier_eviction(&mut self, tier: MemoryTier, bytes: u64)

Records an eviction both globally and for its source tier.

pub fn record_allocator_memory(&mut self, metrics: AllocatorMemoryMetrics)

Records an allocator sample supplied by the selected backend.

pub fn record_process_metrics(&mut self, metrics: ProcessMetrics)

Records an externally obtained process sample.

pub fn sample_process_metrics(&mut self)

Updates process observations using the built-in optional sampler.

pub fn snapshot(&self) -> OffloadReport

Returns an immutable point-in-time report.

pub fn reset(&mut self)

Clears all configuration and observations, including resident peaks.

Trait Implementations

impl Clone for OffloadTelemetry

fn clone(&self) -> OffloadTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OffloadTelemetry

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

Formats the value using the given formatter.

impl Default for OffloadTelemetry

fn default() -> OffloadTelemetry

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OffloadTelemetry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OffloadTelemetry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.