Struct MessageRecord 

pub struct MessageRecord { /* private fields */ }

This struct contains a serialized CloudEvent message in the Kafka shape. Implements StructuredSerializer & BinarySerializer traits.

To instantiate a new MessageRecord from an Event, look at Self::from_event or use StructuredDeserializer::deserialize_structured or BinaryDeserializer::deserialize_binary.

Implementations

impl MessageRecord

pub fn new() -> Self

Create a new empty MessageRecord

pub fn from_event(event: Event) -> Result<Self>

Create a new MessageRecord, filled with event serialized in binary mode.

Trait Implementations

impl BinarySerializer<MessageRecord> for MessageRecord

fn set_spec_version(self, spec_version: SpecVersion) -> Result<Self>

fn set_attribute(self, name: &str, value: MessageAttributeValue) -> Result<Self>

fn set_extension(self, name: &str, value: MessageAttributeValue) -> Result<Self>

fn end_with_data(self, bytes: Vec<u8>) -> Result<MessageRecord>

fn end(self) -> Result<MessageRecord>

impl Default for MessageRecord

fn default() -> Self

Returns the “default value” for a type.

impl StructuredSerializer<MessageRecord> for MessageRecord

fn set_structured_event(self, bytes: Vec<u8>) -> Result<MessageRecord>