Skip to main content

Compressor

rocketmq_protocol::common::compression::compressor

Trait Compressor 

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

Required Methods§

Source

fn compress(&self, src: &[u8], level: i32) -> Result<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]) -> Result<Bytes>

Decompress message by different compressor.

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

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

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§