Struct BrokerRegistrationChangeRecord 

pub struct BrokerRegistrationChangeRecord {
    pub node_id: NodeId,
    pub broker_epoch: i64,
    pub fenced: FencingChange,
    pub in_controlled_shutdown: bool,
    pub log_dirs: Vec<Uuid>,
    pub cordoned_log_dirs: Option<Vec<Uuid>>,
}

Kafka’s BrokerRegistrationChangeRecord (metadata apiKey 17): a delta on the registration of one broker.

As in ClusterControlManager.replay(BrokerRegistrationChangeRecord), the image applies it only when broker_epoch is the epoch of the current registration; against an unknown broker or another epoch it does nothing. in_controlled_shutdown true is Kafka’s IN_CONTROLLED_SHUTDOWN (1) and false is NONE (0); Kafka has no change that leaves controlled shutdown, only a new registration does. An empty log_dirs and a None cordoned_log_dirs mean no change.

Fields

node_id: NodeId

broker_epoch: i64

fenced: FencingChange

in_controlled_shutdown: bool

log_dirs: Vec<Uuid>

KIP-858: the broker’s online log directories after the change.

cordoned_log_dirs: Option<Vec<Uuid>>

KIP-1066: the broker’s cordoned log directories after the change.

Implementations

impl BrokerRegistrationChangeRecord

pub fn no_change(node_id: NodeId, broker_epoch: i64) -> Self

A change that updates nothing, for node_id at broker_epoch. Set the fields to change on the result.

pub fn applied_to( &self, current: &BrokerRegistrationRecord, ) -> BrokerRegistrationRecord

The registration after this change applies to current, as Kafka’s BrokerRegistration.cloneWith builds it. The caller checks the epoch.

Trait Implementations

impl Clone for BrokerRegistrationChangeRecord

fn clone(&self) -> BrokerRegistrationChangeRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BrokerRegistrationChangeRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BrokerRegistrationChangeRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for BrokerRegistrationChangeRecord

impl PartialEq for BrokerRegistrationChangeRecord

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for BrokerRegistrationChangeRecord