Enum RaftMessage 

pub enum RaftMessage<T>
where
    T: LogData,
{
    RequestVote(RequestVoteArgs),
    RequestVoteResponse(RequestVoteResponseResult),
    AppendLog(AppendLogArgs<T>),
    AppendLogResponse(AppendLogResponseResult),
    ReadRequest,
    ReadRequestReply(ReadRequestReplyArgs<T>),
    WriteRequest(WriteRequestArgs),
    WriteRequestReply(bool, Option<SystemNodeId>),
    ConfigChange(UpdateClusterVec),
    ConfigChangeACK(bool),
    InstallSnapshot(InstallSnapshotArgs<T>),
    InstallSnapshotResponse(Term),
}

Variants

RequestVote(RequestVoteArgs)

RequestVoteResponse(RequestVoteResponseResult)

AppendLog(AppendLogArgs<T>)

AppendLogResponse(AppendLogResponseResult)

ReadRequest

ReadRequestReply(ReadRequestReplyArgs<T>)

WriteRequest(WriteRequestArgs)

WriteRequestReply(bool, Option<SystemNodeId>)

ConfigChange(UpdateClusterVec)

ConfigChangeACK(bool)

InstallSnapshot(InstallSnapshotArgs<T>)

InstallSnapshotResponse(Term)

Trait Implementations

impl<T> Clone for RaftMessage<T>

where T: LogData + Clone,

fn clone(&self) -> RaftMessage<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Stopwatch, L: LogData> CoordinationService<T, RaftMessage<L>, LinearMap<SystemNodeId, RaftMetadata, CLUSTER_NODE_COUNT>, RaftMetadata> for RaftService<T, L>

fn new(id: SystemNodeId, metadata: RaftMetadata) -> Self

The id will identify this nodes and the metadata will be used to obtain the root timeout. From that value the heartbeat timeout, the candidate timeout, and the follower timeout will be computed as follows:

• The heartbeat: this is the time between empty RaftMessage::AppendLog are sent to the followers is set to be 20% of the root timeout.
• The candidate timeout: this is the time candidates will wait for the RaftMessage::AppendLogResponse before starting a new election. This is set to be the 75% of the root timeout
• Follower timeout: this is the time a follower will wait for heartbeats, this is, AppendLog messages. This is set to be equal to the root timeout.

fn leader(&self) -> Option<SystemNodeId>

Returns the ID of the cluster leader, or None if it is not set.

fn get_state(&self) -> SystemState

Returns the coordinated state of the system

fn get_current_rule(&self) -> Option<Rule>

Returns the current rule coordinated by the system

fn update_rule( &mut self, communication_service: &mut dyn CommunicationService<Package<SystemNodeId, RaftMessage<L>>>, new_rule: Rule, )

Updates the nodes in the cluster based on [new_config].

fn update_members( &mut self, communication_service: &mut dyn CommunicationService<RaftPackage<L>>, new_config: UpdateClusterVec, )

Updates the nodes in the cluster based on [new_config].

fn update_state( &mut self, communication_service: &mut dyn CommunicationService<RaftPackage<L>>, measurement: Measurement, )

Updates the coordinated state of the system based on measurement

fn process( &mut self, communication_service: &mut dyn CommunicationService<RaftPackage<L>>, package: Option<CoordinationPackage<RaftMessage<L>>>, members: LinearMap<SystemNodeId, RaftMetadata, CLUSTER_NODE_COUNT>, )

Receives a message from another node so that the coordination can occur.

impl<T> Debug for RaftMessage<T>

where T: LogData + Debug,

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

Formats the value using the given formatter.

impl<T: Clone + Debug + Default + Serialize + DeserializeOwned + LogData> Default for RaftMessage<T>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, T> Deserialize<'de> for RaftMessage<T>

where T: LogData + Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: LogData> Display for RaftMessage<T>

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

Formats the value using the given formatter.

impl<T: LogData + Clone + Debug + Default + Serialize + DeserializeOwned> IdentificableMessage for RaftMessage<T>

fn id() -> u8

impl<T> PartialEq for RaftMessage<T>

where T: LogData + PartialEq,

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

where T: LogData + Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> Eq for RaftMessage<T>

where T: LogData + Eq,

impl<T> StructuralPartialEq for RaftMessage<T>

where T: LogData,