Struct rdkafka::message::OwnedHeaders

pub struct OwnedHeaders { /* private fields */ }

A collection of Kafka message headers that owns its backing data.

Kafka supports associating an array of key-value pairs to every message, called message headers. The OwnedHeaders can be used to create the desired headers and to pass them to the producer. See also BorrowedHeaders.

Implementations

impl OwnedHeaders

pub fn new() -> OwnedHeaders

Creates a new OwnedHeaders struct with initial capacity 5.

pub fn new_with_capacity(initial_capacity: usize) -> OwnedHeaders

Creates a new OwnedHeaders struct with the desired initial capacity. The structure is automatically resized as more headers are added.

pub fn insert<V>(self, header: Header<'_, &V>) -> OwnedHeaders

where V: ToBytes + ?Sized,

Inserts a new header.

pub fn as_borrowed(&self) -> &BorrowedHeaders

Generates a read-only BorrowedHeaders reference.

Trait Implementations

impl Clone for OwnedHeaders

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for OwnedHeaders

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

Formats the value using the given formatter.

impl Default for OwnedHeaders

fn default() -> OwnedHeaders

Returns the “default value” for a type.

impl Headers for OwnedHeaders

fn count(&self) -> usize

Returns the number of contained headers.

fn try_get(&self, idx: usize) -> Option<Header<'_, &[u8]>>

Like Headers::get, but returns an option if the header is out of bounds rather than panicking.

fn get(&self, idx: usize) -> Header<'_, &[u8]>

Gets the specified header, where the first header corresponds to index 0.

fn get_as<V>(&self, idx: usize) -> Result<Header<'_, &V>, V::Error>

where V: FromBytes + ?Sized,

Like Headers::get, but the value of the header will be converted to the specified type.

fn try_get_as<V>(&self, idx: usize) -> Option<Result<Header<'_, &V>, V::Error>>

where V: FromBytes + ?Sized,

Like Headers::get, but returns an option if the header is out of bounds rather than panicking.

fn iter(&self) -> HeadersIter<'_, Self>

where Self: Sized,

Iterates over all headers in order.

impl Send for OwnedHeaders

impl Sync for OwnedHeaders