Struct ReplicationMaster 

pub struct ReplicationMaster { /* private fields */ }

Replication Master

WAL append 시 브로드캐스트 채널로 메시지를 전송합니다. 인메모리 tokio::sync::broadcast 채널 기반 MVP 구현.

Implementations

impl ReplicationMaster

pub fn new(capacity: usize) -> (Self, Receiver<ReplicationMessage>)

새 Master 생성. capacity는 채널 버퍼 크기.

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

WAL 데이터를 복제로 전송. LSN을 자동 증가.

data — 직렬화된 WAL 레코드 바이트

pub fn heartbeat(&self)

Heartbeat 전송

pub fn subscribe(&self) -> Receiver<ReplicationMessage>

새 Slave를 위한 구독자 추가

pub fn current_lsn(&self) -> u64

현재 LSN