Struct Struct 

pub struct Struct {
    pub(super) Config: Struct,
    pub(super) CurrentBatch: VecDeque<Vec<u8>>,
    pub(super) BatchStartTime: Option<Instant>,
    pub(super) BatchSizeBytes: usize,
}

Fields

Config: Struct

CurrentBatch: VecDeque<Vec<u8>>

BatchStartTime: Option<Instant>

BatchSizeBytes: usize

Implementations

impl Struct

pub fn new(config: BatchConfig) -> Self

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

pub fn should_flush(&self) -> bool

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

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

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

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

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

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

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

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

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

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

pub fn get_batch_stats(&self) -> BatchStats

pub fn clear_batch(&mut self)

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

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

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