Struct rdkafka::topic_partition_list::TopicPartitionListElem

pub struct TopicPartitionListElem<'a> { /* private fields */ }

One element of the topic partition list.

Implementations

impl<'a> TopicPartitionListElem<'a>

pub fn topic(&self) -> &str

Returns the topic name.

pub fn error(&self) -> KafkaResult<()>

Returns the optional error associated to the specific entry in the TPL.

pub fn partition(&self) -> i32

Returns the partition number.

pub fn offset(&self) -> Offset

Returns the offset.

pub fn set_offset(&mut self, offset: Offset) -> KafkaResult<()>

Sets the offset.

pub fn metadata(&self) -> &str

Returns the optional metadata associated with the entry.

pub fn set_metadata<M>(&mut self, metadata: M)

where M: AsRef<str>,

Sets the optional metadata associated with the entry.

Trait Implementations

impl<'a> PartialEq for TopicPartitionListElem<'a>

fn eq(&self, other: &TopicPartitionListElem<'a>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.