Struct rdkafka_wrap::message::OwnedMessage

pub struct OwnedMessage { /* private fields */ }

A Kafka message that owns its backing data.

An OwnedMessage can be created from a BorrowedMessage using the BorrowedMessage::detach method. OwnedMessages don’t hold any reference to the consumer and don’t use any memory inside the consumer buffer.

Implementations

impl OwnedMessage

pub fn new( payload: Option<Vec<u8, Global>>, key: Option<Vec<u8, Global>>, topic: String, timestamp: Timestamp, partition: i32, offset: i64, headers: Option<OwnedHeaders> ) -> OwnedMessage

Creates a new message with the specified content.

This function is mainly useful in tests of rust-rdkafka itself.

pub fn detach_headers(&mut self) -> Option<OwnedHeaders>

Detaches the OwnedHeaders from this OwnedMessage.

Trait Implementations

impl Clone for OwnedMessage

fn clone(&self) -> OwnedMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for OwnedMessage

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

Formats the value using the given formatter.

impl Message for OwnedMessage

type Headers = OwnedHeaders

The type of headers that this message contains.

fn key(&self) -> Option<&[u8]>

Returns the key of the message, or None if there is no key.

fn payload(&self) -> Option<&[u8]>

Returns the payload of the message, or None if there is no payload.

unsafe fn payload_mut(&mut self) -> Option<&mut [u8]>

Returns a mutable reference to the payload of the message, or None if there is no payload.

fn topic(&self) -> &str

Returns the source topic of the message.

fn partition(&self) -> i32

Returns the partition number where the message is stored.

fn offset(&self) -> i64

Returns the offset of the message within the partition.

fn timestamp(&self) -> Timestamp

Returns the message timestamp.

fn headers(&self) -> Option<&OwnedHeaders>

Returns the headers of the message, or None if there are no headers.

fn payload_view<P>(&self) -> Option<Result<&P, <P as FromBytes>::Error>>where P: FromBytes + ?Sized,

Converts the raw bytes of the payload to a reference of the specified type, that points to the same data inside the message and without performing any memory allocation.

fn key_view<K>(&self) -> Option<Result<&K, <K as FromBytes>::Error>>where K: FromBytes + ?Sized,

Converts the raw bytes of the key to a reference of the specified type, that points to the same data inside the message and without performing any memory allocation.