zeppelin-embed 0.8.0

In-process vector, lexical, and hybrid search for macOS and Apple silicon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! Scoped callbacks at real OS-backed WAL file operations.
use std::cell::RefCell;
use std::io;

/// File operation boundaries used by focused native commit proofs.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum FileEvent {
    /// Immediately before the real append.
    BeforeAppend,
    /// Immediately before the real sync, after append completed.
    BeforeSync,
    /// Immediately after the real sync succeeded.
    AfterSync,
}
type Callback = Box<dyn FnMut(FileEvent) -> io::Result<()>>;
thread_local! { static CALLBACK: RefCell<Option<Callback>> = RefCell::new(None); }
/// Removes a thread-local callback when the proof ends.
pub struct FileOperationScope;
impl FileOperationScope {
    /// Installs one callback on the calling writer thread.
    pub fn install(callback: impl FnMut(FileEvent) -> io::Result<()> + 'static) -> Self {
        CALLBACK.with(|slot| *slot.borrow_mut() = Some(Box::new(callback)));
        Self
    }
}
impl Drop for FileOperationScope {
    fn drop(&mut self) {
        CALLBACK.with(|slot| *slot.borrow_mut() = None);
    }
}
pub(super) fn event(event: FileEvent) -> io::Result<()> {
    CALLBACK.with(|slot| match slot.borrow_mut().as_mut() {
        Some(callback) => callback(event),
        None => Ok(()),
    })
}