Struct MessageCompressor 

pub struct MessageCompressor {
    Config: BatchConfig,
    CurrentBatch: VecDeque<Vec<u8>>,
    BatchStartTime: Option<Instant>,
    BatchSizeBytes: usize,
}

Message compressor with batching capabilities

Fields

Config: BatchConfig

CurrentBatch: VecDeque<Vec<u8>>

BatchStartTime: Option<Instant>

BatchSizeBytes: usize

Implementations

impl MessageCompressor

pub fn new(config: BatchConfig) -> Self

Create a new message compressor with configuration

pub fn add_message(&mut self, MessageData: &[u8]) -> bool

Add a message to the current batch

pub fn should_flush(&self) -> bool

Check if batch should be flushed

pub fn flush_batch(&mut self) -> Result<CompressedBatch, String>

Compress and flush the current batch

fn compress_data( &self, data: &[u8], ) -> Result<(Vec<u8>, CompressionInfo), String>

Compress data using configured algorithm

fn compress_brotli( &self, data: &[u8], ) -> Result<(Vec<u8>, CompressionInfo), String>

Compress using Brotli algorithm

fn compress_gzip( &self, data: &[u8], ) -> Result<(Vec<u8>, CompressionInfo), String>

Compress using Gzip algorithm

fn compress_zlib( &self, data: &[u8], ) -> Result<(Vec<u8>, CompressionInfo), String>

Compress using Zlib algorithm

pub fn decompress_batch( &self, batch: &CompressedBatch, ) -> Result<Vec<Vec<u8>>, String>

Decompress a batch

fn decompress_data( &self, data: &[u8], algorithm: &str, ) -> Result<Vec<u8>, String>

Decompress data using specified algorithm

fn decompress_brotli(&self, data: &[u8]) -> Result<Vec<u8>, String>

Decompress Brotli data

fn decompress_gzip(&self, data: &[u8]) -> Result<Vec<u8>, String>

Decompress Gzip data

fn decompress_zlib(&self, data: &[u8]) -> Result<Vec<u8>, String>

Decompress Zlib data

pub fn get_batch_stats(&self) -> BatchStats

Get current batch statistics

pub fn clear_batch(&mut self)

Clear current batch without flushing

impl MessageCompressor

Utility functions for message compression

pub fn compress_single_message( message_data: &[u8], algorithm: CompressionAlgorithm, level: CompressionLevel, ) -> Result<(Vec<u8>, CompressionInfo), String>

Compress a single message

pub fn calculate_compression_ratio( original_size: usize, compressed_size: usize, ) -> f64

Calculate compression ratio

pub fn estimate_savings(original_size: usize, expected_ratio: f64) -> usize

Estimate compression savings