Enum RaftMessage 

pub enum RaftMessage {
    AppendEntries {
        group_id: GroupId,
        request: AppendEntriesRequest<ChirpsTypeConfig>,
    },
    AppendEntriesResponse {
        group_id: GroupId,
        response: AppendEntriesResponse<ChirpsNodeId>,
    },
    Vote {
        group_id: GroupId,
        request: VoteRequest<ChirpsNodeId>,
    },
    VoteResponse {
        group_id: GroupId,
        response: VoteResponse<ChirpsNodeId>,
    },
    InstallSnapshot {
        group_id: GroupId,
        request: InstallSnapshotRequest<ChirpsTypeConfig>,
    },
    InstallSnapshotResponse {
        group_id: GroupId,
        response: InstallSnapshotResponse<ChirpsNodeId>,
    },
}

Chirps内部でやり取りするRaft RPC。リクエストとレスポンス両方を保持する。

例

use alopex_chirps::raft::{RaftMessage, GroupId};
use alopex_chirps_raft_storage::types::{VoteRequest, Vote};

let msg = RaftMessage::Vote {
    group_id: GroupId(1),
    request: VoteRequest {
        vote: Vote::new(1, 1),
        last_log_id: None,
    },
};
assert_eq!(msg.group_id(), GroupId(1));

Variants

AppendEntries

Fields

group_id: GroupId

request: AppendEntriesRequest<ChirpsTypeConfig>

AppendEntriesResponse

Fields

group_id: GroupId

response: AppendEntriesResponse<ChirpsNodeId>

Vote

Fields

group_id: GroupId

request: VoteRequest<ChirpsNodeId>

VoteResponse

Fields

group_id: GroupId

response: VoteResponse<ChirpsNodeId>

InstallSnapshot

Fields

group_id: GroupId

request: InstallSnapshotRequest<ChirpsTypeConfig>

InstallSnapshotResponse

Fields

group_id: GroupId

response: InstallSnapshotResponse<ChirpsNodeId>

Implementations

impl RaftMessage

pub fn group_id(&self) -> GroupId

Trait Implementations

impl Debug for RaftMessage

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

Formats the value using the given formatter.

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

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RaftMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.