Struct rdkafka::message::BorrowedHeaders

source ·
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::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::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 T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

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

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where 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> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where 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 T
where 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 T
where 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.
source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more