Struct JsonEncoder 

pub struct JsonEncoder { /* private fields */ }

JSON Encoder

Implementations

impl JsonEncoder

pub fn new(options: JsonEncoderOptions) -> Self

Trait Implementations

impl Debug for JsonEncoder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for JsonEncoder

fn default() -> JsonEncoder

Returns the “default value” for a type.

impl Encoder for JsonEncoder

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) -> EncodeResult<Vec<Bytes>>

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.