khive-runtime 0.5.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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

//! khive-runtime: composable Service API used by daemon, MCP server, and CLI.
//!
//! Wraps `StorageBackend` and query compilation into a single Rust API surface.

pub mod actor_identity;
pub mod atomic_plan;
pub mod atomic_prepare;
pub mod atomic_runner;
pub mod blob;
pub mod config;
pub mod config_ledger;
pub mod cost_unit;
pub mod curation;
pub mod daemon;
pub mod embedder_registry;
pub mod engine_config;
pub mod error;
pub mod fusion;
pub mod graph_traversal;
pub mod objectives;
pub mod operations;
pub mod pack;
pub mod phase_events;
pub mod portability;
pub mod presentation;
pub mod reference_resolution;
pub mod reference_ring;
pub mod registry;
pub mod resource;
pub mod retrieval;
pub mod runtime;
pub mod secret_gate;
pub mod validation;

pub use actor_identity::{actor_is_unattributed, resolve_actor, should_warn_unattributed_actor};
pub use atomic_plan::{
    AddEntityPlan, AddNotePlan, AffectedRowGuard, DeletePlan, GovernanceOp, GovernancePlan,
    GtdCompletePlan, GtdTransitionPlan, LinkPlan, MergePlan, PlanPredicate, PlanStatement,
    PostCommitEffect, UpdatePlan,
};
pub use atomic_runner::{
    run_atomic_unit, AtomicOpFailure, AtomicOpPlan, AtomicRunOutcome, AtomicRunnerError,
};
pub use blob::resolve_blob_store;
pub use cost_unit::{base_resource_payload, cost_unit_for_dispatch, resource_payload};
pub use curation::{
    entity_fts_document, note_fts_document, ContentMergeStrategy, EdgeListFilter, EdgePatch,
    EntityDedupMergePolicy, EntityPatch, MergeSummary, NotePatch,
};
#[cfg(unix)]
pub use daemon::{acquire_recovery_lock, pid_path, run_daemon, socket_path, DaemonDispatch};
pub use daemon::{
    active_phase_names, background_task_count, register_active_phase, track_background_task,
    DaemonRequestFrame, DaemonResponseFrame, PhaseGuard, PROTOCOL_VERSION,
};
pub use embedder_registry::{EmbedderProvider, EmbedderRegistry, LatticeEmbedderProvider};
pub use engine_config::{
    config_from_env, BackendConfig, BackendKind, BlobConfig, ConfigError, EngineConfig,
    GitWriteEntryConfig, GitWriteSectionConfig, KhiveConfig, PackConfig, StorageSectionConfig,
};
pub use error::{fts_text_leg_or_err, GuardedWriteFailure, RuntimeError, RuntimeResult};
pub use fusion::FusionStrategy;
pub use graph_traversal::PathNode;
pub use khive_db::{
    checkpoint_once, run_checkpoint_task, run_migrations, CheckpointConfig, CheckpointTick,
    ConnectionPool, StorageBackend,
};
pub use khive_gate::{
    ActorRef, AllowAllGate, AuditDecision, AuditEvent, Gate, GateContext, GateDecision, GateError,
    GateRef, GateRequest, Obligation,
};
pub use khive_storage::types::TraversalOptions;
pub use khive_storage::{EventObservation, EventView, ObservationRole, ReferentKind};
pub use khive_types::namespace::Namespace;
pub use objectives::{
    AmplifiedDecayAwareSalienceObjective, DecayAwareSalienceObjective, GraphProximityObjective,
    MemoryRecallPipeline, NoteCandidate, RerankerObjective, RetrievalCandidate, RrfFusionObjective,
    TemporalRecencyObjective, TextRelevanceObjective, VectorSimilarityObjective,
};
#[cfg(any(test, feature = "fault-injection"))]
pub use operations::{
    arm_fts_fail, arm_fts_fail_many, arm_fts_fail_many_partial, arm_rollback_cleanup_fail,
    arm_vector_fail, arm_vector_fail_after,
};
pub use operations::{
    base_entity_endpoint_rules, base_entity_rule_allows, endpoint_matches,
    hex_prefix_to_uuid_pattern, merge_entry_metadata, EdgeEndpointKind, EntityCreateSpec, LinkSpec,
    NoteSearchHit, QueryResult, Resolved,
};
pub use pack::{
    resolve_explicit_namespace, DispatchHook, HandlerDef, KindHook, NoteKindSpec,
    NoteLifecycleSpec, PackByIdResolver, PackFactory, PackInstall, PackLoadError, PackRegistration,
    PackRegistry, PackRuntime, PackSchemaCollisionError, PackSchemaPlan, ParamDef, RequestIdentity,
    SchemaPlan, VerbCategory, VerbPresentationPolicy, VerbRegistry, VerbRegistryBuilder,
    VerifiedActor, Visibility,
};
pub use phase_events::{emit_phase_event, is_benign_shutdown_cancellation};
pub use portability::{ImportSummary, KgArchive};
pub use presentation::{
    apply_redundancy_drop, micros_to_iso, present, render_format, OutputFormat, PresentationMode,
};
pub use reference_resolution::{resolve_reference, ReferenceCandidate, ReferenceResolution};
pub use reference_ring::{ReferenceRing, RingEntry};
pub use registry::{ObjectiveRegistry, RegisteredObjective};
pub use resource::{cpu_delta_us, process_resource_usage, ProcessResourceUsage};
pub use retrieval::{SearchHit, SearchSource};
pub use runtime::{
    assert_captured_db_anchor_consistent, assert_db_anchor_consistent, parse_pack_list,
    resolve_db_anchor, resolve_project_actor_id, runtime_config_from_khive_config, BackendId,
    EntityTypeValidatorFn, KhiveRuntime, NamespaceToken, NoteMutationHookFn, RuntimeConfig,
};
pub use secret_gate::SecretMatch;
pub use validation::{
    GraphPatch, GraphSnapshot, RuleFn, RuleId, Severity, ValidationContext, ValidationReport,
    ValidationRule, Violation,
};