Trait kafka_protocol::compression::Compressor
source · pub trait Compressor<B: ByteBufMut> {
type BufMut: ByteBufMut;
fn compress<R, F>(buf: &mut B, f: F) -> Result<R, EncodeError>
where
F: FnOnce(&mut Self::BufMut) -> Result<R, EncodeError>;
}Expand description
A trait for record compression algorithms.
Required Associated Types§
sourcetype BufMut: ByteBufMut
type BufMut: ByteBufMut
Target buffer type for compression.
Required Methods§
sourcefn compress<R, F>(buf: &mut B, f: F) -> Result<R, EncodeError>where
F: FnOnce(&mut Self::BufMut) -> Result<R, EncodeError>,
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.