pub struct BorrowedHeaders;
Expand description

A zero-copy collection of Kafka message headers.

Provides a read-only access to headers owned by a Kafka consumer or producer or by an OwnedHeaders struct.

Implementations§

source§

impl BorrowedHeaders

source

pub fn detach(&self) -> OwnedHeaders

Clones the content of BorrowedHeaders and returns an OwnedHeaders that can outlive the consumer.

This operation requires memory allocation and can be expensive.

Trait Implementations§

source§

impl Headers for BorrowedHeaders

source§

fn count(&self) -> usize

Returns the number of contained headers.
source§

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.
source§

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

Gets the specified header, where the first header corresponds to index 0. Read more
source§

fn get_as<V>( &self, idx: usize ) -> Result<Header<'_, &V>, <V as FromBytes>::Error>where V: FromBytes + ?Sized,

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

fn try_get_as<V>( &self, idx: usize ) -> Option<Result<Header<'_, &V>, <V as FromBytes>::Error>>where V: FromBytes + ?Sized,

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

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

Iterates over all headers in order.

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.