Enum Membership 

pub enum Membership {
    InProgress,
    Assigned(Vec<TopicPartition>),
    Revoked(Vec<TopicPartition>),
}

Where membership stands after a step.

Variants

InProgress

Still joining or syncing; call again.

Assigned(Vec<TopicPartition>)

Assigned and stable. The partitions are this member’s to fetch.

Revoked(Vec<TopicPartition>)

These partitions were given up. The caller must stop fetching them before the next call, because another member is about to be given them.

Under the eager protocol that is everything this member held; under the cooperative one it is only what moved, and the rest keeps being read.

Trait Implementations

impl Clone for Membership

fn clone(&self) -> Membership

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Membership

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

Formats the value using the given formatter.

impl Eq for Membership

impl PartialEq for Membership

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Membership