Struct MessageBatch

pub struct MessageBatch {
    pub content: Content,
}

Represents a message in a stream processing engine.

Fields

content: Content

Message content

Implementations

impl MessageBatch

pub fn new_binary(content: Vec<Bytes>) -> Self

pub fn from_json<T: Serialize>(value: &T) -> Result<Self, Error>

pub fn new_arrow(content: RecordBatch) -> Self

pub fn from_string(content: &str) -> Self

Create a message from a string.

pub fn as_string(&self) -> Result<Vec<String>, Error>

Parse the message content into a string.

pub fn as_binary(&self) -> &Vec<Bytes>

Get the binary content of the message.

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

Trait Implementations

impl Clone for MessageBatch

fn clone(&self) -> MessageBatch

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessageBatch

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

Formats the value using the given formatter.