Struct TopicPartitionInfo 

pub struct TopicPartitionInfo { /* private fields */ }

A class containing leadership, replicas and ISR information for a topic partition.

Implementations

impl TopicPartitionInfo

pub fn with_elr_last_known_elr( partition: i32, leader: Option<Node>, replicas: Vec<Node>, isr: Vec<Node>, elr: Vec<Node>, last_known_elr: Vec<Node>, ) -> Self

Create an instance with the provided parameters.

Arguments

• partition - the partition id
• leader - the leader of the partition or None if there is none.
• replicas - the replicas of the partition in the same order as the replica assignment (the preferred replica is the head of the list)
• isr - the in-sync replicas
• elr - the eligible leader replicas
• last_known_elr - the last known eligible leader replicas.

pub fn new( partition: i32, leader: Option<Node>, replicas: Vec<Node>, isr: Vec<Node>, ) -> Self

Create an instance with the provided parameters, without eligible leader replica information.

Arguments

• partition - the partition id
• leader - the leader of the partition or None if there is none.
• replicas - the replicas of the partition in the same order as the replica assignment (the preferred replica is the head of the list)
• isr - the in-sync replicas

pub fn partition(&self) -> i32

Returns the partition id.

pub fn leader(&self) -> Option<&Node>

Returns the leader of the partition or None if there is none.

pub fn replicas(&self) -> &[Node]

Returns the replicas of the partition in the same order as the replica assignment. The preferred replica is the head of the list.

Brokers with version lower than 0.11.0.0 return the replicas in unspecified order due to a bug.

pub fn isr(&self) -> &[Node]

Returns the in-sync replicas of the partition. The ordering is unspecified.

pub fn elr(&self) -> Option<&[Node]>

Returns the eligible leader replicas of the partition, or None if unavailable. The ordering is unspecified.

pub fn last_known_elr(&self) -> Option<&[Node]>

Returns the last known eligible leader replicas of the partition, or None if unavailable. The ordering is unspecified.

Trait Implementations

impl Clone for TopicPartitionInfo

fn clone(&self) -> TopicPartitionInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicPartitionInfo

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

Formats the value using the given formatter.

impl Display for TopicPartitionInfo

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

Formats the value using the given formatter.

impl Hash for TopicPartitionInfo

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for TopicPartitionInfo

fn eq(&self, other: &TopicPartitionInfo) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for TopicPartitionInfo

impl StructuralPartialEq for TopicPartitionInfo