Struct rdkafka::topic_partition_list::TopicPartitionListElem

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

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<TopicPartitionListElem<'a>> for TopicPartitionListElem<'a>

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.