khive-db 0.12.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 SqliteWriter {
    pub(super) fn map_direct_error(
        &self,
        error: rusqlite::Error,
        operation: &'static str,
        stage: khive_storage::error::SqliteWriteStage,
    ) -> StorageError {
        crate::timeout_sink::maybe_emit_busy(
            &self.db,
            crate::timeout_sink::Site::StandaloneSqlBridge,
            &error,
        );
        let error = crate::error::with_write_stage(map_rusqlite_err(error, operation), stage);
        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 native =
            crate::error::native_write_failure(&failure.error, failure.stage).map(|mut native| {
                native.settlement_unknown = matches!(
                    &failure.poison_reason,
                    Some(standalone_batch::BatchPoisonReason::RollbackFailed(_))
                );
                native
            });
        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"),
        };
        let error = match native {
            Some(failure) => error.with_sqlite_write_failure(failure),
            None => error,
        };
        if self.observe_direct_errors {
            self.pool.record_direct_writer_error(&error);
        }
        error
    }
}