Struct ClickHouseBackup 

pub struct ClickHouseBackup { /* private fields */ }

ClickHouse backup client

Implementations

impl ClickHouseBackup

pub fn new(config: ClickHouseConfig) -> Result<Self, ClickHouseError>

Create a new ClickHouse backup client

pub fn is_enabled(&self) -> bool

Check if backup is enabled

pub async fn record_connection( &self, conn_id: u64, meta: &ConnMeta, ) -> Result<(), ClickHouseError>

Record a new connection

pub async fn flush(&self) -> Result<usize, ClickHouseError>

Flush buffered records to ClickHouse

pub fn start_flush_task(self: Arc<Self>) -> JoinHandle<()>

Start background flush task

pub async fn ensure_table(&self) -> Result<(), ClickHouseError>

Create table if not exists

pub async fn buffered_count(&self) -> usize

Get buffered record count

pub async fn archive_raft_log( &self, index: u64, term: u64, operation: &str, payload: &str, ) -> Result<(), ClickHouseError>

Record a raft log entry

pub async fn flush_raft_logs(&self) -> Result<usize, ClickHouseError>

Flush buffered raft logs

pub async fn ensure_tables(&self) -> Result<(), ClickHouseError>

Create tables if not exists