khive-storage 0.9.0

Storage capability contracts and backend-neutral request context.
Documentation
//! 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 operation_context;
pub mod request_context;
pub mod sparse;
pub mod sql;
pub mod telemetry;
#[cfg(feature = "test-support")]
pub mod test_support;
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, UploadId,
    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, TopLevelMaintenance};
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::{
    BatchWriteError, BatchWriteErrorClass, BatchWriteErrorCount, BatchWriteRetryability,
    BatchWriteSummary, BoundedCount, DeleteMode, DirectedNeighborHit, Direction, Edge, EdgeFilter,
    EdgeSeekPage, EdgeSortField, EdgeUpsertDisposition, EdgeUpsertRefusal, EdgeUpsertRequest,
    EdgeUpsertResult, GraphPath, GuardedBatchOutcome, GuardedBatchRefusal, GuardedEdgeBatchRefusal,
    GuardedEdgeBatchUpsertOutcome, GuardedEdgeUpsertOutcome, GuardedWriteOutcome,
    IndexRebuildScope, LimitReport, LinkId, MissingEndpoints, NeighborCursor, 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_BATCH_WRITE_ERROR_DETAILS, MAX_BATCH_WRITE_ERROR_MESSAGE_CHARS, 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,
};