Struct sea_streamer_kafka::TopicPartitionList

pub struct TopicPartitionList { /* private fields */ }

A structure to store and manipulate a list of topics and partitions with optional offsets.

Implementations

impl TopicPartitionList

pub fn new() -> TopicPartitionList

Creates a new empty list with default capacity.

pub fn with_capacity(capacity: usize) -> TopicPartitionList

Creates a new empty list with the specified capacity.

pub fn from_topic_map( topic_map: &HashMap<(String, i32), Offset> ) -> Result<TopicPartitionList, KafkaError>

Given a topic map, generates a new TopicPartitionList.

pub fn ptr(&self) -> *mut rd_kafka_topic_partition_list_s

Returns the pointer to the internal librdkafka structure.

pub fn count(&self) -> usize

Returns the number of elements in the list.

pub fn capacity(&self) -> usize

Returns the capacity of the list.

pub fn add_topic_unassigned<'a>( &'a mut self, topic: &str ) -> TopicPartitionListElem<'a>

Adds a topic with unassigned partitions to the list.

pub fn add_partition<'a>( &'a mut self, topic: &str, partition: i32 ) -> TopicPartitionListElem<'a>

Adds a topic and partition to the list.

pub fn add_partition_range( &mut self, topic: &str, start_partition: i32, stop_partition: i32 )

Adds a topic and partition range to the list.

pub fn set_partition_offset( &mut self, topic: &str, partition: i32, offset: Offset ) -> Result<(), KafkaError>

Sets the offset for an already created topic partition. It will fail if the topic partition isn’t in the list.

pub fn add_partition_offset( &mut self, topic: &str, partition: i32, offset: Offset ) -> Result<(), KafkaError>

Adds a topic and partition to the list, with the specified offset.

pub fn find_partition( &self, topic: &str, partition: i32 ) -> Option<TopicPartitionListElem<'_>>

Given a topic name and a partition number, returns the corresponding list element.

pub fn set_all_offsets(&mut self, offset: Offset) -> Result<(), KafkaError>

Sets all partitions in the list to the specified offset.

pub fn elements(&self) -> Vec<TopicPartitionListElem<'_>>

Returns all the elements of the list.

pub fn elements_for_topic<'a>( &'a self, topic: &str ) -> Vec<TopicPartitionListElem<'a>>

Returns all the elements of the list that belong to the specified topic.

pub fn to_topic_map(&self) -> HashMap<(String, i32), Offset>

Returns a hashmap-based representation of the list.

Trait Implementations

impl Clone for TopicPartitionList

fn clone(&self) -> TopicPartitionList

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TopicPartitionList

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

Formats the value using the given formatter.

impl Default for TopicPartitionList

fn default() -> TopicPartitionList

Returns the “default value” for a type.

impl PartialEq for TopicPartitionList

fn eq(&self, other: &TopicPartitionList) -> 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 !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Send for TopicPartitionList

impl Sync for TopicPartitionList