Skip to main content

MessageBatch

Type Alias MessageBatch 

Source
pub type MessageBatch = Vec<Message>;
Expand description

A batch of messages being processed together.

Message batches are used by processors to emit multiple messages from a single input, and by batch outputs to collect messages before writing.

§Example

use fiddler::{Message, MessageBatch};

let batch: MessageBatch = vec![
    Message { bytes: b"msg1".to_vec(), ..Default::default() },
    Message { bytes: b"msg2".to_vec(), ..Default::default() },
];

Aliased Type§

pub struct MessageBatch { /* private fields */ }