Struct Topics

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

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

Implementations

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.

pub fn is_empty(&self) -> bool

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

Provides an iterator over the underlying topics.

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

A convenience 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> Debug for Topics<'a>

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

Formats the value using the given formatter.

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.