Struct SwitchoverBuffer 

pub struct SwitchoverBuffer { /* private fields */ }

Switchover buffer for zero-downtime primary transitions

Implementations

impl SwitchoverBuffer

pub fn new(config: BufferConfig) -> Self

Create a new switchover buffer

pub fn is_buffering(&self) -> bool

Check if currently buffering

pub fn state(&self) -> BufferState

Get current state

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

Subscribe to state changes

pub fn start_buffering(&self)

Start buffering (called when switchover begins)

pub fn stop_buffering(&self)

Stop buffering (called when switchover completes or fails)

pub fn buffer_query( &self, sql: String, params: Vec<Vec<u8>>, client_id: u64, ) -> Result<Receiver<BufferResult>>

Buffer a query (returns receiver for result)

pub async fn drain<F, Fut>(&self, execute_fn: F)

where F: Fn(String, Vec<Vec<u8>>) -> Fut, Fut: Future<Output = Result<()>>,

Drain buffer and replay queries to new primary

The execute_fn is called for each buffered query to execute it against the new primary.

pub fn fail_all(&self, error: &str)

Fail all buffered queries (called if switchover fails)

pub fn len(&self) -> usize

Get current buffer length

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn stats(&self) -> BufferStatsSnapshot

Get buffer statistics