Struct PartitionReassignment 

pub struct PartitionReassignment { /* private fields */ }

A partition reassignment, which has been listed via Admin::list_partition_reassignments.

Corresponds to org.apache.kafka.clients.admin.PartitionReassignment.

Implementations

impl PartitionReassignment

pub fn new( replicas: Vec<i32>, adding_replicas: Vec<i32>, removing_replicas: Vec<i32>, ) -> Self

Creates a partition reassignment from its replica sets.

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

The brokers which this partition currently resides on.

Mirrors replicas().

pub fn adding_replicas(&self) -> &[i32]

The brokers that we are adding this partition to as part of a reassignment. A subset of replicas.

Mirrors addingReplicas().

pub fn removing_replicas(&self) -> &[i32]

The brokers that we are removing this partition from as part of a reassignment. A subset of replicas.

Mirrors removingReplicas().

Trait Implementations

impl Clone for PartitionReassignment

fn clone(&self) -> PartitionReassignment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionReassignment

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

Formats the value using the given formatter.

impl Display for PartitionReassignment

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

Formats the value using the given formatter.

impl PartialEq for PartitionReassignment

fn eq(&self, other: &PartitionReassignment) -> 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 PartitionReassignment

impl StructuralPartialEq for PartitionReassignment