khive-runtime 0.10.0

Composable Service API: entity/note CRUD, graph traversal, hybrid search, curation.
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
57
58
59
60
61
62

//! A single-test binary keeps the process generation sequence isolated.

use std::sync::Arc;

use khive_db::StorageBackend;
use khive_runtime::{BackendId, KhiveRuntime, RuntimeConfig};

#[tokio::test(flavor = "current_thread")]
async fn diagnostics_main_pool_generation_tracks_runtime_reconstruction() {
    let auxiliary = Arc::new(StorageBackend::memory().unwrap());
    let secondary = KhiveRuntime::from_backend(
        auxiliary,
        RuntimeConfig {
            backend_id: BackendId::parse("secondary").unwrap(),
            ..RuntimeConfig::no_embeddings()
        },
    );
    let main = Arc::new(StorageBackend::memory().unwrap());
    let runtime = KhiveRuntime::from_backend(Arc::clone(&main), RuntimeConfig::no_embeddings());
    let first = runtime.db_diagnostics().await.unwrap();
    assert_eq!(first.process.pool_generation, 1);

    drop(main.pool().try_writer().unwrap());
    drop(main.pool().reader().unwrap());
    let repeated = runtime.clone().db_diagnostics().await.unwrap();
    assert_eq!(repeated.process, first.process);
    assert!(repeated.writer_contention.writer_acquisitions > 0);
    assert!(repeated.reader_contention.reader_acquisitions > 0);

    let another_handle =
        KhiveRuntime::from_backend(Arc::clone(&main), RuntimeConfig::no_embeddings());
    assert_eq!(
        another_handle.db_diagnostics().await.unwrap().process,
        first.process
    );
    let routed = secondary.with_core_backend(main);
    assert_eq!(
        routed.db_diagnostics().await.unwrap().process,
        first.process
    );

    // Construction must count even when this generation is never observed.
    drop(KhiveRuntime::from_backend(
        Arc::new(StorageBackend::memory().unwrap()),
        RuntimeConfig::no_embeddings(),
    ));
    let replacement = KhiveRuntime::from_backend(
        Arc::new(StorageBackend::memory().unwrap()),
        RuntimeConfig::no_embeddings(),
    );
    let after = replacement.db_diagnostics().await.unwrap();
    assert_eq!(after.process.pool_generation, 3);
    assert_eq!(after.process.pid, first.process.pid);
    assert_eq!(after.process.started_at, first.process.started_at);
    assert_eq!(after.writer_contention.writer_acquisitions, 0);
    assert_eq!(after.reader_contention.reader_acquisitions, 0);
    assert_eq!(after.checkpoint_counters, first.checkpoint_counters);
    assert_eq!(
        runtime.db_diagnostics().await.unwrap().process,
        first.process
    );
}