slatedb 0.15.0

A cloud native embedded storage engine built on object storage.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::wal::{WalError, WalObserver, WalStatus, WalStatusListener};

#[derive(Clone, Debug)]
pub(crate) struct DisabledWalObserver {
    status: WalStatus,
}

impl DisabledWalObserver {
    pub(crate) fn new(status: WalStatus) -> Self {
        Self { status }
    }
}

impl WalObserver for DisabledWalObserver {
    fn status(&self) -> Result<WalStatus, WalStatus> {
        Ok(self.status.clone())
    }

    fn subscribe(&self, _listener: WalStatusListener) -> Result<(), WalError> {
        Ok(())
    }
}