Struct kafka_protocol::compression::Snappy

pub struct Snappy;

Snappy compression algorithm. See Kafka’s broker configuration for more information.

Trait Implementations

impl<B: ByteBufMut> Compressor<B> for Snappy

type BufMut = BytesMut

Target buffer type for compression.

fn compress<R, F>(buf: &mut B, f: F) -> Result<R, EncodeError>where
    F: FnOnce(&mut Self::BufMut) -> Result<R, EncodeError>,

Compresses into provided ByteBufMut, with records encoded by F into R.

impl<B: ByteBuf> Decompressor<B> for Snappy

type Buf = Bytes

Target buffer type for decompression.

fn decompress<R, F>(buf: &mut B, f: F) -> Result<R, DecodeError>where
    F: FnOnce(&mut Self::Buf) -> Result<R, DecodeError>,

Decompress records from B mapped using F into R.