Enum ReplicationMessage 

pub enum ReplicationMessage {
    WalEntry {
        node_id: u32,
        lsn: u64,
        timestamp: u64,
        data: Vec<u8>,
    },
    Heartbeat {
        node_id: u32,
        lsn: u64,
    },
    RequestFrom {
        node_id: u32,
        lsn: u64,
    },
    Acknowledge {
        node_id: u32,
        lsn: u64,
    },
    VoteRequest {
        node_id: u32,
        term: u64,
        last_lsn: u64,
    },
    VoteResponse {
        node_id: u32,
        voter_id: u32,
        term: u64,
        granted: bool,
    },
    Promotion {
        node_id: u32,
        term: u64,
    },
}

Replication 메시지 타입

Variants

WalEntry

WAL 항목 전송. node_id: 발신 노드 식별자 lsn: 로그 시퀀스 번호 timestamp: LWW (Last-Writer-Wins) 기반 충돌 해결용

Fields

node_id: u32

lsn: u64

timestamp: u64

data: Vec<u8>

Heartbeat

연결 유지 신호

Fields

node_id: u32

lsn: u64

RequestFrom

특정 LSN부터 재전송 요청

Fields

node_id: u32

lsn: u64

Acknowledge

동기화 완료 확인

Fields

node_id: u32

lsn: u64

VoteRequest

마스터 승격(Failover) 표를 요청 term: 선출 임기 번호 (중복 선출 방지)

Fields

node_id: u32

term: u64

last_lsn: u64

VoteResponse

마스터 승격(Failover) 투표 응답 voter_id: 투표한 노드 ID (집계용)

Fields

node_id: u32

voter_id: u32

term: u64

granted: bool

Promotion

새 마스터 승격 알림

Fields

node_id: u32

term: u64

Implementations

impl ReplicationMessage

pub fn lsn(&self) -> u64

메시지의 LSN 반환

pub fn is_wal_entry(&self) -> bool

WAL Entry 여부

Trait Implementations

impl Clone for ReplicationMessage

fn clone(&self) -> ReplicationMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ReplicationMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ReplicationMessage

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

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ReplicationMessage