Module compression 

Compression support for message bodies

This module provides compression and decompression utilities for Celery message bodies. Compression can significantly reduce message size for large payloads.

Supported Algorithms

• gzip - Standard gzip compression (requires gzip feature)
• zstd - Zstandard compression (requires zstd-compression feature)

Example

use celers_protocol::compression::{Compressor, CompressionType};

let compressor = Compressor::new(CompressionType::Gzip);
let data = b"Hello, World!".repeat(100);
let compressed = compressor.compress(&data).unwrap();
let decompressed = compressor.decompress(&compressed).unwrap();
assert_eq!(data, decompressed);

Structs

Compressor

Compressor with configurable algorithm and level

Enums

CompressionError

Compression error

CompressionType

Compression algorithm type

Functions

auto_decompress

Decompress data with auto-detection

detect_compression

Auto-detect compression type from data header

Type Aliases

CompressionResult

Result type for compression operations