Enum RaftEntry 

pub enum RaftEntry {
    RegisterNode {
        node_id: u64,
        address: String,
        labels: HashMap<String, String>,
    },
    DeregisterNode {
        node_id: u64,
    },
    SetService(Box<ServiceConfig>),
    RemoveService(String),
    AssignWorkload {
        service: String,
        replica_idx: u32,
        node_id: u64,
    },
    UnassignWorkload {
        service: String,
        replica_idx: u32,
        node_id: u64,
    },
    UpdateNodeStatus {
        node_id: u64,
        status: NodeStatus,
        resources: NodeResources,
    },
}

A single Raft log entry — a mutation to cluster state.

Variants

RegisterNode

Register a new node in the cluster.

Fields

node_id: u64

address: String

labels: HashMap<String, String>

DeregisterNode

Remove a node from the cluster.

Fields

node_id: u64

SetService(Box<ServiceConfig>)

Add or update a service definition.

RemoveService(String)

Remove a service.

AssignWorkload

Assign a workload replica to a node.

Fields

service: String

replica_idx: u32

node_id: u64

UnassignWorkload

Unassign a workload replica from a node.

Fields

service: String

replica_idx: u32

node_id: u64

UpdateNodeStatus

Update a node’s status and resource info.

Fields

node_id: u64

status: NodeStatus

resources: NodeResources

Trait Implementations

impl Clone for RaftEntry

fn clone(&self) -> RaftEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RaftEntry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RaftEntry

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RaftEntry

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

where __S: Serializer,

Serialize this value into the given Serde serializer.