Struct kafka_protocol::compression::Gzip

pub struct Gzip;

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

Trait Implementations

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

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 Gzip

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.