Struct kafka::client::metadata::Topics

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

A view on the loaded metadata about topics and their partitions.

Methods

impl<'a> Topics<'a>

pub fn new(client: &KafkaClient) -> Topics

Constructs a view of the currently loaded topic metadata from the specified kafka client.

pub fn len(&self) -> usize

Retrieves the number of the underlying topics.

Important traits for TopicIter<'a>

impl<'a> Iterator for TopicIter<'a> type Item = Topic<'a>;

pub fn iter(&'a self) -> TopicIter<'a>

Provides an iterator over the underlying topics.

Important traits for TopicNames<'a>

impl<'a> Iterator for TopicNames<'a> type Item = &'a str;

pub fn names(&'a self) -> TopicNames<'a>

A conveniece method to return an iterator over the topics' names.

pub fn contains(&'a self, topic: &str) -> bool

A convenience method to determine whether the specified topic is known.

pub fn partitions(&'a self, topic: &str) -> Option<Partitions<'a>>

Retrieves the partitions of a specified topic.

Trait Implementations

impl<'a> IntoIterator for &'a Topics<'a>

type Item = Topic<'a>

The type of the elements being iterated over.

type IntoIter = TopicIter<'a>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'a> IntoIterator for Topics<'a>

type Item = Topic<'a>

The type of the elements being iterated over.

type IntoIter = TopicIter<'a>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<'a> Debug for Topics<'a>

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

Formats the value using the given formatter.