Struct ProtobufEncoder 

pub struct ProtobufEncoder { /* private fields */ }

Protobuf Encoder

Implementations

impl ProtobufEncoder

pub fn new( options: ProtobufEncoderOptions, message_descriptor: MessageDescriptor, ) -> Self

Trait Implementations

impl Encoder for ProtobufEncoder

fn encode(&self, batch: &EventBatch) -> EncodeResult<Bytes>

Encodes a single EventBatch into a single byte stream. This is typically used for batch-oriented sinks like S3 or GCS.

fn encode_individual(&self, batch: &EventBatch) -> Result<Vec<Bytes>, Error>

Encodes an EventBatch into multiple independent byte streams (one per event). This is typically used for message-oriented sinks like Kafka. Default implementation just returns a single Vec with the output of encode.