khive-db 0.10.0

SQLite storage backend: entities, edges, notes, events, FTS5, sqlite-vec vectors.
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use super::*;

impl StorageBackend {
    /// File-backed SQLite database whose volume advisory lock files live in
    /// `volume_lock_dir`. Every cooperating process must choose the same directory.
    pub fn sqlite_with_volume_lock_dir(
        path: impl AsRef<Path>,
        volume_lock_dir: std::path::PathBuf,
    ) -> Result<Self, SqliteError> {
        Self::sqlite_with_pool_config(
            path,
            PoolConfig {
                volume_lock_dir: Some(volume_lock_dir),
                ..PoolConfig::default()
            },
            None,
        )
    }

    /// The host supplies the same captured policies used for daemon identity.
    pub fn sqlite_with_max_readers_and_policies(
        path: impl AsRef<Path>,
        max_readers: Option<usize>,
        wal_ceiling: WalCeilingPolicy,
        disk_guard_config: crate::EffectiveDiskGuardConfig,
        volume_lock_dir: std::path::PathBuf,
    ) -> Result<Self, SqliteError> {
        Self::sqlite_with_pool_config(
            path,
            PoolConfig {
                wal_ceiling,
                disk_guard_config: Some(disk_guard_config),
                volume_lock_dir: Some(volume_lock_dir),
                ..PoolConfig::default()
            },
            max_readers,
        )
    }

    #[cfg(any(test, feature = "test-support"))]
    pub fn sqlite_for_test_with_policies(
        path: impl AsRef<Path>,
        wal_ceiling: WalCeilingPolicy,
        disk_guard_config: crate::EffectiveDiskGuardConfig,
    ) -> Result<Self, SqliteError> {
        Self::sqlite_with_pool_config(
            path,
            PoolConfig {
                wal_ceiling,
                disk_guard_config: Some(disk_guard_config),
                ..PoolConfig::for_test()
            },
            Some(2),
        )
    }
}