Enum ClusterCommand 

pub enum ClusterCommand {
    AddNode {
        node_id: NodeId,
        raft_id: u64,
        addr: String,
        is_primary: bool,
    },
    RemoveNode {
        node_id: NodeId,
    },
    AssignSlots {
        node_id: NodeId,
        slots: Vec<SlotRange>,
    },
    RemoveSlots {
        node_id: NodeId,
        slots: Vec<SlotRange>,
    },
    PromoteReplica {
        replica_id: NodeId,
    },
    BeginMigration {
        slot: u16,
        from: NodeId,
        to: NodeId,
    },
    CompleteMigration {
        slot: u16,
        new_owner: NodeId,
    },
}

Commands that modify cluster configuration.

These are replicated through Raft to ensure all nodes agree on the cluster topology.

Variants

AddNode

Add a new node to the cluster.

Fields

node_id: NodeId

raft_id: u64

addr: String

is_primary: bool

RemoveNode

Remove a node from the cluster.

Fields

node_id: NodeId

AssignSlots

Assign slots to a node.

Fields

node_id: NodeId

slots: Vec<SlotRange>

RemoveSlots

Remove specific slots from a node.

Fields

node_id: NodeId

slots: Vec<SlotRange>

PromoteReplica

Promote a replica to primary (during failover).

Fields

replica_id: NodeId

BeginMigration

Mark a slot as migrating.

Fields

slot: u16

from: NodeId

to: NodeId

CompleteMigration

Complete a slot migration.

Fields

slot: u16

new_owner: NodeId

Trait Implementations

impl Clone for ClusterCommand

fn clone(&self) -> ClusterCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClusterCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClusterCommand

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ClusterCommand

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

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 ClusterCommand

impl StructuralPartialEq for ClusterCommand