Struct kafka_protocol::messages::broker_registration_request::BrokerRegistrationRequestBuilder
source · pub struct BrokerRegistrationRequestBuilder { /* private fields */ }Expand description
Builder for BrokerRegistrationRequest.
Implementations§
source§impl BrokerRegistrationRequestBuilder
impl BrokerRegistrationRequestBuilder
sourcepub fn broker_id(&mut self, value: BrokerId) -> &mut Self
pub fn broker_id(&mut self, value: BrokerId) -> &mut Self
The broker ID.
Supported API versions: 0-3
sourcepub fn cluster_id(&mut self, value: StrBytes) -> &mut Self
pub fn cluster_id(&mut self, value: StrBytes) -> &mut Self
The cluster id of the broker process.
Supported API versions: 0-3
sourcepub fn incarnation_id(&mut self, value: Uuid) -> &mut Self
pub fn incarnation_id(&mut self, value: Uuid) -> &mut Self
The incarnation id of the broker process.
Supported API versions: 0-3
sourcepub fn listeners(&mut self, value: IndexMap<StrBytes, Listener>) -> &mut Self
pub fn listeners(&mut self, value: IndexMap<StrBytes, Listener>) -> &mut Self
The listeners of this broker
Supported API versions: 0-3
sourcepub fn features(&mut self, value: IndexMap<StrBytes, Feature>) -> &mut Self
pub fn features(&mut self, value: IndexMap<StrBytes, Feature>) -> &mut Self
The features on this broker
Supported API versions: 0-3
sourcepub fn rack(&mut self, value: Option<StrBytes>) -> &mut Self
pub fn rack(&mut self, value: Option<StrBytes>) -> &mut Self
The rack which this broker is in.
Supported API versions: 0-3
sourcepub fn is_migrating_zk_broker(&mut self, value: bool) -> &mut Self
pub fn is_migrating_zk_broker(&mut self, value: bool) -> &mut Self
If the required configurations for ZK migration are present, this value is set to true
Supported API versions: 1-3
sourcepub fn log_dirs(&mut self, value: Vec<Uuid>) -> &mut Self
pub fn log_dirs(&mut self, value: Vec<Uuid>) -> &mut Self
Log directories configured in this broker which are available.
Supported API versions: 2-3
sourcepub fn previous_broker_epoch(&mut self, value: i64) -> &mut Self
pub fn previous_broker_epoch(&mut self, value: i64) -> &mut Self
The epoch before a clean shutdown.
Supported API versions: 3
sourcepub fn unknown_tagged_fields(
&mut self,
value: BTreeMap<i32, Bytes>,
) -> &mut Self
pub fn unknown_tagged_fields( &mut self, value: BTreeMap<i32, Bytes>, ) -> &mut Self
Other tagged fields
sourcepub fn build(
&self,
) -> Result<BrokerRegistrationRequest, BrokerRegistrationRequestBuilderError>
pub fn build( &self, ) -> Result<BrokerRegistrationRequest, BrokerRegistrationRequestBuilderError>
Trait Implementations§
source§impl Clone for BrokerRegistrationRequestBuilder
impl Clone for BrokerRegistrationRequestBuilder
source§fn clone(&self) -> BrokerRegistrationRequestBuilder
fn clone(&self) -> BrokerRegistrationRequestBuilder
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl !Freeze for BrokerRegistrationRequestBuilder
impl RefUnwindSafe for BrokerRegistrationRequestBuilder
impl Send for BrokerRegistrationRequestBuilder
impl Sync for BrokerRegistrationRequestBuilder
impl Unpin for BrokerRegistrationRequestBuilder
impl UnwindSafe for BrokerRegistrationRequestBuilder
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit)