Struct GzipCompressor 

pub struct GzipCompressor;

Available on crate features dial9 and pipeline only.

Gzips the segment payload in-memory. Sets the content_encoding and write_back_extension metadata keys so downstream stages know the payload is gzipped. Already-gzipped segments (detected by magic bytes) pass through unchanged.

Trait Implementations

impl Debug for GzipCompressor

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

Formats the value using the given formatter.

impl Default for GzipCompressor

fn default() -> GzipCompressor

Returns the “default value” for a type.

impl SegmentProcessor for GzipCompressor

fn name(&self) -> &'static str

Human-readable name for this processor (used in metrics).

fn process( &mut self, data: SegmentData, ) -> Pin<Box<dyn Future<Output = Result<SegmentData, ProcessError>> + Send + '_>>

Process a segment, transforming or consuming its data. Returns the (possibly modified) data for the next processor, or an error to skip this segment.

fn initialize( &mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

Initialize this processor on the worker’s Tokio runtime before the pipeline begins processing segments.

fn finalize_dump( &mut self, completion: &DumpCompletion, ) -> Pin<Box<dyn Future<Output = Option<String>> + Send + '_>>

Called once per finished dump in triggered mode (see crate::dump), in pipeline order, so stages can flush any per-dump state they accumulated. Return the S3 key of a manifest written for this dump, or None; the last Some across the pipeline lands on DumpReceipt::manifest_key.