Trait Chunking

Source
pub trait Chunking {
    // Required method
    fn chunk(&self, bytes: Bytes) -> Result<Vec<Bytes>, Error>;
}
Expand description

Trait for encoding formats that optionally support chunking, for use with sinks that have payload size limits (such as UDP).

Chunking is an extension to the standard Encoder trait, allowing large encoded events to be split into multiple frames for transmission.

Required Methods§

Source

fn chunk(&self, bytes: Bytes) -> Result<Vec<Bytes>, Error>

Chunks the input into frames.

Implementors§