Struct RaftMetadata 

pub struct RaftMetadata {
    pub timeout: u64,
}

Fields

timeout: u64

Implementations

impl RaftMetadata

pub fn new(timeout: u64) -> Self

Trait Implementations

impl Clone for RaftMetadata

fn clone(&self) -> RaftMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CoordinationMetadataBuilder<RaftMetadata> for RaftMetadataBuilder

fn build(args: &SystemNodeArgs) -> RaftMetadata

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 Debug for RaftMetadata

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

Formats the value using the given formatter.

impl Default for RaftMetadata

fn default() -> RaftMetadata

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for RaftMetadata

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for RaftMetadata

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

Formats the value using the given formatter.

impl Serialize for RaftMetadata

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl BasicMetadata for RaftMetadata

impl SerializableMetadata for RaftMetadata