Struct ReplicationNode 

pub struct ReplicationNode {
    pub node_id: u32,
    pub cluster_size: usize,
    pub quorum_write_timeout: Duration,
    /* private fields */
}

클러스터 노드 (Quorum 기반 리더 선출)

Fields

node_id: u32

자기 자신의 노드 ID

cluster_size: usize

클러스터 전체 노드 수 (Quorum 계산용)

quorum_write_timeout: Duration

Quorum Write 타임아웃 (기본 5초, ReplicationConfig에서 설정 가능)

Implementations

impl ReplicationNode

pub fn new( node_id: u32, cluster_size: usize, initial_role: NodeRole, tx: Sender<ReplicationMessage>, ) -> Self

새로운 노드 생성

pub fn new_from_config( node_id: u32, initial_role: NodeRole, tx: Sender<ReplicationMessage>, config: &ReplicationConfig, ) -> Self

[ReplicationConfig]에서 timeout을 읽어 노드를 생성하는 편의 팩토리

DbConfig::replication을 통해 quorum_write_timeout을 설정하려면 이 메서드를 사용하세요.

pub async fn role(&self) -> NodeRole

현재 역할 조회

pub fn term(&self) -> u64

현재 임기 번호 조회

pub async fn replicate(&self, data: Vec<u8>) -> Result<u64, String>

(Master 용) WAL 레코드 발행 — Quorum Write

cluster_size == 1 (또는 quorum == 1) 이면 기존과 동일하게 즉시 반환. 그 외에는 quorum 수만큼의 Slave ACK를 받은 뒤 반환한다. quorum_write_timeout 내에 ACK를 받지 못하면 Err를 반환한다.

pub async fn send_heartbeat(&self)

(Master 용) Heartbeat 송신

pub async fn run_receiver_loop<F>( &self, rx: Receiver<ReplicationMessage>, apply_fn: F, ) -> Result<(), NodeError>

where F: FnMut(u64, u64, &[u8]) -> Result<(), String>,

클러스터 메시지 수신 및 적용 루프

pub async fn start_election(&self) -> bool

(Slave/Candidate용) Heartbeat 타임아웃 시 선거 시작

1. 자신을 Candidate로 승격
2. term 증가
3. 자신에게 투표 (자가 투표)
4. VoteRequest 브로드캐스트