Struct rdkafka::topic_partition_list::TopicPartitionList

pub struct TopicPartitionList {
    pub topics: Topics,
}

Map of topics with optionally partition configuration.

Fields

topics: Topics

Methods

impl TopicPartitionList

fn from_rdkafka(tp_list: *const RDKafkaTopicPartitionList) -> TopicPartitionList

Create list based on a list from the rdkafka side.

fn new() -> TopicPartitionList

Create an empty list

fn with_topics(topic_names: &[&str]) -> TopicPartitionList

Create list with specified topics with default configuration

fn add_topic_with_partitions(&mut self, topic: &str, partitions: &Vec<i32>)

Add topic with partitions configured

fn add_topic_with_partitions_and_offsets(
    &mut self,
    topic: &str,
    partitions: &Vec<(i32, i64)>
)

Add topic with partitions and offsets configured

fn create_native_topic_partition_list(&self) -> *mut RDKafkaTopicPartitionList

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, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl PartialEq for TopicPartitionList

fn eq(&self, __arg_0: &TopicPartitionList) -> bool

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

fn ne(&self, __arg_0: &TopicPartitionList) -> bool

This method tests for !=.

impl Deref for TopicPartitionList

type Target = Topics

The resulting type after dereferencing

fn deref(&self) -> &Topics

The method called to dereference a value