Struct AddRaftVoterOptions 

pub struct AddRaftVoterOptions { /* private fields */ }

Options for adding a voter to the KRaft controller quorum.

Implementations

impl AddRaftVoterOptions

pub fn new(voter_id: i32, voter_directory_id: [u8; 16]) -> Self

Creates options with a 60-second controller timeout and no listeners.

pub fn cluster_id(self, cluster_id: impl Into<String>) -> Self

Sets the expected Kafka cluster ID, when known.

pub fn timeout(self, timeout: Duration) -> Self

Sets the controller-side voter addition timeout.

pub fn listener(self, listener: RaftVoterListener) -> Self

Adds one listener endpoint to the voter registration.

pub fn ack_when_committed(self, ack_when_committed: bool) -> Self

Requests that v1 wait until the voter addition is committed.

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

Returns the configured cluster ID.

pub fn request_timeout(&self) -> Duration

Returns the controller-side timeout.

pub fn voter_id(&self) -> i32

Returns the voter broker ID.

pub fn voter_directory_id(&self) -> [u8; 16]

Returns the voter directory UUID.

pub fn listeners(&self) -> &[RaftVoterListener]

Returns the listener endpoints.

pub fn ack_when_committed_ref(&self) -> bool

Returns whether the request waits for the committed quorum change.

Trait Implementations

impl Clone for AddRaftVoterOptions

fn clone(&self) -> AddRaftVoterOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AddRaftVoterOptions

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

Formats the value using the given formatter.

impl Eq for AddRaftVoterOptions

impl PartialEq for AddRaftVoterOptions

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AddRaftVoterOptions