Struct kafka::client::metadata::Partitions

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

Metadata relevant to partitions of a particular topic.

Methods

impl<'a> Partitions<'a>

pub fn len(&self) -> usize

Retrieves the number of the topic's partitions.

pub fn is_empty(&self) -> bool

Tests for .len() > 0.

Important traits for PartitionIter<'a>

impl<'a> Iterator for PartitionIter<'a> type Item = Partition<'a>;

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

Retrieves an iterator of the partitions of the underlying topic.

pub fn partition(&self, partition_id: i32) -> Option<Partition<'a>>

Finds a specified partition identified by its id.

pub fn available_ids(&self) -> Vec<i32>

Convenience method to retrieve the identifiers of all currently "available" partitions. Such partitions are known to have a leader broker and can be sent messages to.

Trait Implementations

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

type Item = Partition<'a>

The type of the elements being iterated over.

type IntoIter = PartitionIter<'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 Partitions<'a>

type Item = Partition<'a>

The type of the elements being iterated over.

type IntoIter = PartitionIter<'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 Partitions<'a>

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

Formats the value using the given formatter.