pub struct Member {
pub member_id: KafkaString,
pub rack_id: Option<KafkaString>,
pub member_epoch: i32,
pub client_id: KafkaString,
pub client_host: KafkaString,
pub subscribed_topic_names: Vec<KafkaString>,
pub assignment: Assignment,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}Fields§
§member_id: KafkaStringThe member ID.
rack_id: Option<KafkaString>The member rack ID.
member_epoch: i32The current member epoch.
client_id: KafkaStringThe client ID.
client_host: KafkaStringThe client host.
subscribed_topic_names: Vec<KafkaString>The subscribed topic names.
assignment: AssignmentThe current assignment.
_unknown_tagged_fields: Vec<RawTaggedField>Implementations§
Source§impl Member
impl Member
pub fn with_member_id(self, value: KafkaString) -> Self
pub fn with_rack_id(self, value: Option<KafkaString>) -> Self
pub fn with_member_epoch(self, value: i32) -> Self
pub fn with_client_id(self, value: KafkaString) -> Self
pub fn with_client_host(self, value: KafkaString) -> Self
pub fn with_subscribed_topic_names(self, value: Vec<KafkaString>) -> Self
pub fn with_assignment(self, value: Assignment) -> Self
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self>
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()>
pub fn encoded_len(&self, version: i16) -> Result<usize>
Trait Implementations§
impl StructuralPartialEq for Member
Auto Trait Implementations§
impl !Freeze for Member
impl RefUnwindSafe for Member
impl Send for Member
impl Sync for Member
impl Unpin for Member
impl UnsafeUnpin for Member
impl UnwindSafe for Member
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more