Struct MemberDescription 

pub struct MemberDescription { /* private fields */ }

A detailed description of a single group member in the cluster.

Implementations

impl MemberDescription

pub fn new( member_id: impl Into<String>, group_instance_id: Option<String>, rack_id: Option<String>, client_id: impl Into<String>, host: impl Into<String>, assignment: MemberAssignment, target_assignment: Option<MemberAssignment>, member_epoch: Option<i32>, upgraded: Option<bool>, ) -> Self

Creates a member description with all fields.

Arguments

• member_id - the consumer id of the group member.
• group_instance_id - the instance id of the group member, or None if not set.
• rack_id - the rack id of the group member, or None if not set.
• client_id - the client id of the group member.
• host - the host where the group member is running.
• assignment - the assignment of the group member.
• target_assignment - the target assignment of the member (consumer groups only).
• member_epoch - the epoch of the member (consumer groups only).
• upgraded - whether the member uses the consumer protocol (consumer groups only).

pub fn consumer_id(&self) -> &str

Returns the consumer id of the group member.

pub fn group_instance_id(&self) -> Option<&str>

Returns the instance id of the group member.

pub fn rack_id(&self) -> Option<&str>

Returns the rack id of the group member.

It is only available for consumer groups using the new consumer group protocol (group.protocol=consumer).

pub fn client_id(&self) -> &str

Returns the client id of the group member.

pub fn host(&self) -> &str

Returns the host where the group member is running.

pub fn assignment(&self) -> &MemberAssignment

Returns the assignment of the group member. Provided for both classic group and consumer group.

pub fn target_assignment(&self) -> Option<&MemberAssignment>

Returns the target assignment of the member (consumer groups only).

pub fn member_epoch(&self) -> Option<i32>

Returns the epoch of the group member. The optional is set to an integer if the member is in a GroupType::Consumer group, and to None if it is in a GroupType::Classic group.

pub fn upgraded(&self) -> Option<bool>

Returns the flag indicating whether a member within a GroupType::Consumer group uses the GroupType::Consumer protocol. The optional is set to true if it does, to false if it does not, and to None if it is unknown or if the group is a GroupType::Classic group.

Trait Implementations

impl Clone for MemberDescription

fn clone(&self) -> MemberDescription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemberDescription

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

Formats the value using the given formatter.

impl Display for MemberDescription

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

Formats the value using the given formatter.

impl Hash for MemberDescription

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 MemberDescription

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

impl StructuralPartialEq for MemberDescription