Struct CompressTelemetry 

pub struct CompressTelemetry {
    pub codec: &'static str,
    pub bytes_in: u64,
    pub bytes_out: u64,
    pub gpu_seconds: Option<f64>,
    pub oom: bool,
}

v0.8 #55: per-op telemetry returned by CodecRegistry::compress_with_telemetry / decompress_with_telemetry. Lets the s4-server caller stamp Prometheus metrics (s4_gpu_compress_seconds, s4_gpu_throughput_bytes_per_sec, s4_gpu_oom_total) without s4-codec needing a metrics dep itself — callback pattern keeps the codec dep tree slim.

Fields:

• codec: stable codec kind name (CodecKind::as_str() — "cpu-zstd" / "nvcomp-zstd" / etc).
• bytes_in: input length to the operation. For compress this is the uncompressed input; for decompress this is the compressed input.
• bytes_out: output length. For compress = compressed; for decompress = decompressed.
• gpu_seconds: Some(elapsed_secs) for GPU-backed codecs (Nvcomp*), None for CPU codecs (CpuZstd / Passthrough / CpuGzip). Callers skip the GPU metric stamp when this is None.
• oom: true iff the operation failed with an OOM-classified error. The associated Result is still Err(...); this flag exists so the stamp helper can tell OOM apart from generic backend errors without introspecting the CodecError chain at the call site.

Fields

codec: &'static str

bytes_in: u64

bytes_out: u64

gpu_seconds: Option<f64>

oom: bool

Implementations

impl CompressTelemetry

pub fn cpu(codec: &'static str, bytes_in: u64, bytes_out: u64) -> Self

CPU-codec convenience constructor — gpu_seconds = None, oom = false. Used by passthrough / cpu-zstd / cpu-gzip path.

pub fn gpu( codec: &'static str, bytes_in: u64, bytes_out: u64, seconds: f64, ) -> Self

GPU-codec convenience constructor — populates gpu_seconds from the measured wall-clock duration of the inner compress / decompress call.

pub fn with_oom(self) -> Self

Mark this telemetry as the OOM-failure shape — paired with Err(CodecError::Backend(...)). Callers stamp s4_gpu_oom_total{codec=...} when this is true.

Trait Implementations

impl Clone for CompressTelemetry

fn clone(&self) -> CompressTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompressTelemetry

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

Formats the value using the given formatter.

impl Copy for CompressTelemetry