Struct TelemetrySnapshot 

pub struct TelemetrySnapshot {

    pub segments_processed: u64,
    pub frames_data: u64,
    pub frames_terminator: u64,
    pub frames_digest: u64,
    pub bytes_plaintext: u64,
    pub bytes_compressed: u64,
    pub bytes_ciphertext: u64,
    pub bytes_overhead: u64,
    pub compression_ratio: f64,
    pub throughput_plaintext_bytes_per_sec: f64,
    pub elapsed: Duration,
    pub stage_times: StageTimes,
    pub output: Option<Vec<u8>>,
}

Core telemetry snapshot. Captures counters, ratios, throughput, stage timings, and elapsed duration.

Fields

segments_processed: u64

frames_data: u64

frames_terminator: u64

frames_digest: u64

bytes_plaintext: u64

bytes_compressed: u64

bytes_ciphertext: u64

bytes_overhead: u64

compression_ratio: f64

throughput_plaintext_bytes_per_sec: f64

elapsed: Duration

stage_times: StageTimes

output: Option<Vec<u8>>

The final encrypted stream bytes, if the output sink was memory-backed.

• None if the output was written directly to a file or external sink.
• Some(Vec<u8>) if the pipeline wrote into an in-memory buffer.

This field is primarily useful in tests, benchmarks, or integrations where we want to inspect the produced ciphertext alongside telemetry counters and stage timings.

Implementations

impl TelemetrySnapshot

pub fn from( counters: &TelemetryCounters, timer: &TelemetryTimer, segments: Option<u32>, ) -> Self

pub fn total_stage_time(&self) -> Duration

pub fn has_all_stages(&self, expected: &[Stage]) -> bool

pub fn sanity_check(&self) -> bool

pub fn output_bytes(&self) -> u64

pub fn attach_output(&mut self, buf: Vec<u8>)

🔧 Attach output buffer to snapshot

Trait Implementations

impl Clone for TelemetrySnapshot

fn clone(&self) -> TelemetrySnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetrySnapshot

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TelemetrySnapshot

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TelemetrySnapshot

fn eq(&self, other: &TelemetrySnapshot) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TelemetrySnapshot

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TelemetrySnapshot