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

use super::*;

impl SqliteWriter {
    pub(super) fn map_direct_error(
        &self,
        error: rusqlite::Error,
        operation: &'static str,
    ) -> StorageError {
        crate::timeout_sink::maybe_emit_busy(
            &self.db,
            crate::timeout_sink::Site::StandaloneSqlBridge,
            &error,
        );
        let error = map_rusqlite_err(error, operation);
        if self.observe_direct_errors {
            self.pool.record_direct_writer_error(&error);
        }
        error
    }

    pub(super) fn map_direct_batch_failure(&self, failure: BatchFailure) -> StorageError {
        crate::timeout_sink::maybe_emit_busy(
            &self.db,
            crate::timeout_sink::Site::StandaloneSqlBridge,
            &failure.error,
        );
        let error = match failure.poison_reason {
            Some(poison_reason) => StorageError::driver(
                StorageCapability::Sql,
                "execute_batch",
                PoisonedBatchError {
                    original: failure.error,
                    poison_reason,
                },
            ),
            None => map_rusqlite_err(failure.error, "execute_batch"),
        };
        if self.observe_direct_errors {
            self.pool.record_direct_writer_error(&error);
        }
        error
    }
}