Compressor

rocketmq_common::common::compression::compressor

Trait Compressor 

Source 
pub trait Compressor {
    // Required methods
    fn compress(&self, src: &[u8], level: i32) -> RocketMQResult<Bytes>;
    fn decompress(&self, src: &[u8]) -> RocketMQResult<Bytes>;
}

Required Methods§

Source

fn compress(&self, src: &[u8], level: i32) -> RocketMQResult<Bytes>

Compress message by different compressor.

§Arguments
  • src - Bytes ready to compress.
  • level - Compression level used to balance compression rate and time consumption.
§Returns

Compressed byte data or an std::io::Error.

Source

fn decompress(&self, src: &[u8]) -> RocketMQResult<Bytes>

Decompress message by different compressor.

§Arguments
  • src - Bytes ready to decompress.
§Returns

Decompressed byte data or an std::io::Error.

Implementors§