Enum MetadataCommand 

pub enum MetadataCommand {
    CreateTopic {
        config: TopicConfig,
        partition_assignments: Vec<Vec<NodeId>>,
    },
    DeleteTopic {
        name: String,
    },
    UpdateTopicConfig {
        name: String,
        config: HashMap<String, String>,
    },
    AddPartitions {
        topic: String,
        new_assignments: Vec<Vec<NodeId>>,
    },
    UpdatePartitionLeader {
        partition: PartitionId,
        leader: NodeId,
        epoch: u64,
    },
    UpdatePartitionIsr {
        partition: PartitionId,
        isr: Vec<NodeId>,
        leader_epoch: u64,
    },
    ReassignPartition {
        partition: PartitionId,
        replicas: Vec<NodeId>,
    },
    RegisterNode {
        info: NodeInfo,
    },
    DeregisterNode {
        node_id: NodeId,
    },
    UpdateNode {
        node_id: NodeId,
        info: NodeInfo,
    },
    UpdateClusterConfig {
        config: HashMap<String, String>,
    },
    UpdateConsumerGroup {
        group: ConsumerGroup,
    },
    DeleteConsumerGroup {
        group_id: GroupId,
    },
    Noop,
    Batch(Vec<MetadataCommand>),
}

Raft log entry types for metadata operations

Variants

CreateTopic

Create a new topic

Fields

config: TopicConfig

partition_assignments: Vec<Vec<NodeId>>

DeleteTopic

Delete a topic

Fields

name: String

UpdateTopicConfig

Update topic configuration

Fields

name: String

config: HashMap<String, String>

AddPartitions

Add partitions to existing topic

Fields

topic: String

new_assignments: Vec<Vec<NodeId>>

UpdatePartitionLeader

Update partition leader

Fields

partition: PartitionId

leader: NodeId

epoch: u64

UpdatePartitionIsr

Update partition ISR (includes leader epoch for fencing)

Fields

partition: PartitionId

isr: Vec<NodeId>

leader_epoch: u64

Leader epoch of the proposer — stale-epoch proposals are rejected

ReassignPartition

Reassign partition replicas

Fields

partition: PartitionId

replicas: Vec<NodeId>

RegisterNode

Register a new node

Fields

info: NodeInfo

DeregisterNode

Deregister a node

Fields

node_id: NodeId

UpdateNode

Update node metadata

Fields

node_id: NodeId

info: NodeInfo

UpdateClusterConfig

Update cluster-wide configuration

Fields

config: HashMap<String, String>

UpdateConsumerGroup

Update consumer group state (full snapshot)

Fields

group: ConsumerGroup

DeleteConsumerGroup

Delete consumer group

Fields

group_id: GroupId

Noop

No-op (for heartbeats/leader election)

Batch(Vec<MetadataCommand>)

Batch of commands applied in a single Raft consensus round.

Semantics: best-effort — each command is applied independently. Some commands may succeed while others fail. The batch is atomic at the Raft log level (single entry, single fsync), but individual commands can return errors without rolling back prior successes.

Used by propose_batch for higher throughput.

Trait Implementations

impl Clone for MetadataCommand

fn clone(&self) -> MetadataCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetadataCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MetadataCommand

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MetadataCommand

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for MetadataCommand

impl StructuralPartialEq for MetadataCommand