Struct PartitionRecord 

pub struct PartitionRecord {
    pub topic: String,
    pub partition: i32,
    pub leader: NodeId,
    pub replicas: Vec<NodeId>,
    pub isr: Vec<NodeId>,
    pub leader_epoch: i32,
    pub adding_replicas: Vec<NodeId>,
    pub removing_replicas: Vec<NodeId>,
    pub directories: Vec<Uuid>,
    pub partition_epoch: i32,
}

Fields

topic: String

partition: i32

leader: NodeId

replicas: Vec<NodeId>

isr: Vec<NodeId>

leader_epoch: i32

Per-partition leader epoch. Bumped on every leader change. Older on-disk metadata is not migrated.

adding_replicas: Vec<NodeId>

Replicas being added in an in-flight reassignment. Empty when no reassignment in flight. KIP-455.

removing_replicas: Vec<NodeId>

Replicas being removed in an in-flight reassignment. Empty when no reassignment in flight. KIP-455.

directories: Vec<Uuid>

KIP-858: the log-directory UUID hosting each replica, parallel to Self::replicas (same index order). Uuid::nil() is DirectoryId.UNASSIGNED — the owning broker has not yet reported its AssignReplicasToDirs for this replica. The controller maps a broker’s failed-dir UUID to the partitions it must fail over by matching this against the broker’s replica slot.

partition_epoch: i32

KIP-631: per-partition state epoch. Increments on every state change (leader election, ISR change, reassignment). Set to 0 on creation. Default of -1 matches the KIP-631 schema default for compatibility with records written before this field was added.

Trait Implementations

impl Clone for PartitionRecord

fn clone(&self) -> PartitionRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionRecord

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

Formats the value using the given formatter.

impl Default for PartitionRecord

fn default() -> PartitionRecord

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PartitionRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for PartitionRecord

impl PartialEq for PartitionRecord

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

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 PartitionRecord