khive-storage 0.8.0

Storage capability contracts and backend-neutral request context.
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76

//! Storage capability traits: `SqlAccess`, `VectorStore`, `TextSearch`,
//! `GraphStore`, `NoteStore`, `EntityStore`, `EventStore`, `SparseStore`,
//! `BlobStore`, and `AttachmentStore`.

pub mod agent;
pub mod attachment;
pub mod blob;
pub mod capability;
pub mod entity;
pub mod error;
pub mod event;
pub mod graph;
pub mod note;
pub mod request_context;
pub mod sparse;
pub mod sql;
pub mod telemetry;
pub mod text;
pub mod tx_registry;
pub mod types;
pub mod usage;
pub mod vectors;

pub use agent::AgentStore;
pub use attachment::{Attachment, AttachmentStore, AttachmentSubstrate, NewAttachment};
pub use blob::{
    BlobOrphanSweepConfig, BlobOrphanSweepResult, BlobStore, ContentRef, MAX_BLOB_WHOLE_BYTES,
};
pub use capability::StorageCapability;
pub use entity::{Entity, EntityFilter, EntityStore};
pub use error::{StorageError, WriterTaskRequestState};

pub use event::{
    Event, EventFilter, EventObservation, EventStore, EventView, ObservationRole, ReferentKind,
};
pub use graph::GraphStore;
pub use note::{FilterOp, Note, NoteFilter, NoteStore, SortDir};
pub use request_context::{
    await_request_read_phase, capture_request_read_context, effective_request_read_deadline,
    ensure_request_read_active, inherit_request_read_cancellation, inherit_request_read_context,
    request_read_is_cancelled, request_read_timeout_from_env, scope_request_read_cancellation,
    scope_request_read_deadline, scope_request_read_deadline_at,
    wait_for_request_read_cancellation, RequestReadContext, RequestReadDeadline,
    RequestReadStopReason, DEFAULT_REQUEST_READ_TIMEOUT_SECS,
};
pub use sparse::SparseStore;
pub use sql::{AtomicUnitOp, BoxFuture, SqlAccess, SqlReader, SqlWriter};
pub use telemetry::{
    ChannelBackoffArmedPayload, ChannelBackoffResetPayload, ChannelHeartbeatPersistFailedPayload,
    ChannelPollFailedPayload, ChannelPollStartedPayload, ChannelPollSucceededPayload,
    CheckpointOutcomeRecordedPayload, ConfigLockedPayload, LifecycleEvent, PhaseCancelledPayload,
    PhaseCompletedPayload, PhaseStartedPayload,
};
pub use text::TextSearch;
pub use types::StorageResult;
pub use vectors::VectorStore;

pub use types::{
    BatchWriteSummary, DeleteMode, DirectedNeighborHit, Direction, Edge, EdgeFilter, EdgeSeekPage,
    EdgeSortField, GraphPath, GuardedBatchOutcome, GuardedBatchRefusal, GuardedWriteOutcome,
    IndexRebuildScope, LinkId, MissingEndpoints, NeighborHit, NeighborQuery, OrphanSweepConfig,
    OrphanSweepResult, Page, PageRequest, PathNode, PropertyFilter, PropertyOp, SeekCursor,
    SeekPage, SortDirection, SortOrder, SparseRecord, SparseSearchHit, SparseSearchRequest,
    SparseVector, SqlRow, SqlStatement, SqlValue, TextDocument, TextFilter, TextGatherMode,
    TextIndexStats, TextQueryMode, TextSearchHit, TextSearchOptions, TextSearchRequest,
    TextTermStats, TextTermStatsRequest, TimeRange, TraversalExecutionBudget, TraversalOptions,
    TraversalRequest, VectorIndexKind, VectorMetadataFilter, VectorRecord, VectorSearchHit,
    VectorSearchRequest, VectorStoreCapabilities, VectorStoreInfo, DEFAULT_TRAVERSAL_LIMIT,
    MAX_SPARSE_SEARCH_TOP_K, MAX_TRAVERSAL_DEPTH, MAX_TRAVERSAL_LIMIT, MAX_TRAVERSAL_MILLIS,
    MAX_TRAVERSAL_ROOTS, MAX_TRAVERSAL_WORK,
};

pub use khive_types::{
    AgentRecord, AgentState, EdgeCategory, EdgeRelation, EventOutcome, SubstrateKind,
    TerminalReason,
};