Struct ReplicationSlave 

pub struct ReplicationSlave { /* private fields */ }

Replication Slave

Master로부터 ReplicationMessage::WalEntry를 수신하여 apply_fn 콜백으로 로컬 DB에 재생합니다.

MVP: 인메모리 tokio::sync::broadcast 채널 기반.

Implementations

impl ReplicationSlave

pub fn new() -> Self

pub fn last_applied_lsn(&self) -> Option<u64>

마지막으로 적용된 LSN 반환 (u64::MAX = 아직 없음)

pub async fn replay_n<F>( &self, rx: &mut Receiver<ReplicationMessage>, count: usize, apply_fn: F, ) -> Result<usize, ReplayError>

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

브로드캐스트 채널로부터 메시지를 수신하고 apply_fn으로 재생.

count 개의 메시지를 처리 후 반환 (0 = 무한 루프). 실제 서버에서는 tokio task로 spawn.

Trait Implementations

impl Default for ReplicationSlave

fn default() -> Self

Returns the “default value” for a type.