iridium_core 0.1.12

SQL Server-compatible Rust engine core for Iridium SQL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use super::{EngineCatalog, EngineStorage};
use crate::error::DbError;
use crate::executor::database::{CheckpointManager, CheckpointManagerService};
use crate::executor::durability::RecoveryCheckpoint;

impl<C, S> CheckpointManager for CheckpointManagerService<C, S>
where
    C: EngineCatalog,
    S: EngineStorage,
{
    fn export_checkpoint(&self) -> Result<String, DbError> {
        self.state.to_checkpoint().to_json()
    }

    fn import_checkpoint(&self, payload: &str) -> Result<(), DbError> {
        let checkpoint = RecoveryCheckpoint::<C>::from_json(payload)?;
        self.state.apply_checkpoint(checkpoint);
        Ok(())
    }
}