#[cfg(test)]
mod test_process;
pub mod actor_identity;
pub mod agent_lifecycle;
#[doc(hidden)]
pub use khive_retrieval::ann::registry as ann_registry;
pub mod atomic_message;
pub mod atomic_plan;
pub mod atomic_prepare;
pub mod atomic_runner;
pub mod audit_batch;
pub mod blob;
pub mod bounded_read;
pub mod build_info;
mod code_map_runtime;
pub mod comm_recipient;
pub mod comm_transport;
pub mod config;
pub mod config_ledger;
pub mod cost_unit;
pub mod credentials;
mod visibility_receipts;
pub use visibility_receipts::AuthenticatedVisibilityReceipt;
pub mod curation;
pub mod daemon;
pub mod email_message_id;
pub mod embedder_registry;
pub mod engine_config;
pub mod entity_write;
pub mod error;
mod error_projection;
mod event_cursor_walk;
mod event_page;
mod event_store_guard;
pub mod events_split;
mod fence_identity;
pub mod file_policy;
pub mod fusion;
pub mod graph_traversal;
mod index_repair;
pub use index_repair::IndexRepairReport;
pub mod input_schema;
pub mod keyed_memory;
#[cfg(test)]
mod keyed_memory_tests;
pub mod keyed_message;
mod kg_read;
mod live_until;
mod mailbox_view;
mod note_create;
mod note_index;
mod note_read;
pub mod note_search_ann;
mod note_store_guard;
pub mod note_write;
#[cfg(test)]
mod note_write_tests;
pub mod objectives;
pub mod operations;
mod outbound_email_policy;
pub use outbound_email_policy::OutboundEmailPolicy;
pub mod pack;
pub mod pack_metadata;
mod params;
pub mod phase_events;
pub mod portability;
pub mod preference_verification;
pub mod presentation;
pub mod process_group;
pub mod process_retry;
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(crate) mod secret_gate_finalizer;
mod sql_include;
#[cfg(test)]
mod stage_overlap_tests;
mod stage_seam;
mod streams;
pub mod telemetry_config;
pub use streams::{
refusal_value, StreamAppendDisposition, StreamAppendFailure, StreamAppendSpec,
StreamBatchMember, StreamBatchRefusal, StreamObservation, StreamWriteSpec,
};
pub mod time_anchor;
pub use khive_storage::usage;
pub mod validation;
pub use actor_identity::{actor_is_unattributed, resolve_actor, should_warn_unattributed_actor};
pub use agent_lifecycle::{
apply_transition, spawn_fingerprint, AgentRecord, AgentState, IllegalTransition,
TerminalReason, Transition, Trigger,
};
pub use atomic_message::{create_notes_atomic_with_report, AtomicNoteSpec};
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,
CommittedPostCommitEffects,
};
pub use blob::{
resolve_blob_store, resolve_blob_store_for_mode, BlobHydrator, GovernedBlobError, VerifiedBlob,
DEFAULT_BLOB_HYDRATION_BYTES,
};
pub use build_info::{BuildInfo, BUILD_INFO, BUILD_VERSION};
pub use config::{ann_fresh_tail_enabled_from_env, process_ref_from_env, WalCeilingSource};
pub use cost_unit::{base_resource_payload, cost_unit_for_dispatch, resource_payload};
pub use curation::{
entity_embedding_text, entity_fts_document, entity_merge_guard_compared_values,
entity_merge_guard_error, entity_merge_guard_refusal_message, note_embedding_text,
note_fts_document, validate_entity_merge_floor, ContentMergeStrategy, EdgeListFilter,
EdgePatch, EntityDedupMergePolicy, EntityMergeGuard, EntityPatch, GuardedNoteMerge,
MergeAssertion, MergeEdgeConflictPreimage, MergeEdgePreimage, MergeSummary,
MergeTxBudgetReport, MergeTxLimits, NoteMergeGuard, NotePatch, NoteUpdatePolicy,
};
#[cfg(unix)]
pub use daemon::{acquire_recovery_lock, pid_path, run_daemon, socket_path, DaemonDispatch};
pub use daemon::{
active_phase_names, background_task_count, background_task_names, daemon_shutdown_token,
recall_ledger_snapshot, register_active_phase, spawn_named_tracked_task, track_background_task,
track_named_background_task, track_recall_ledger_task, DaemonRequestFrame, DaemonResponseFrame,
PhaseGuard, PROTOCOL_VERSION, UNNAMED_BACKGROUND_TASK,
};
pub use email_message_id::{EmailMessageIdDomains, HISTORICAL_DOMAINS_ENV};
pub use embedder_registry::{EmbedderProvider, EmbedderRegistry, LatticeEmbedderProvider};
pub use engine_config::{
config_from_env, resolve_wal_ceiling, BackendConfig, BackendKind, BlobConfig,
BrainSectionConfig, ConfigError, EngineConfig, GateSectionConfig, GitWriteEntryConfig,
GitWriteSectionConfig, KhiveConfig, PackConfig, ResolvedWalCeiling, StorageSectionConfig,
};
pub use error::{
fts_text_leg_or_err, AdmissionFailureContext, AuditObligationFailure, AuditObligationReason,
ChannelIngestFailureClass, DenialAuditOutcome, DenialReceipt, DispatchError, DomainDisposition,
GuardedWriteFailure, ReceiptRefusal, RefusalEventContext, RefusalEventRecording,
RefusalRecordingErrorClass, RuntimeError, RuntimeResult, WriterPoolCheckoutTimeoutContext,
WriterTaskFailureContext, SQLITE_WAL_CAPACITY_REFUSED_STAGE,
SQLITE_WAL_CAPACITY_UNAVAILABLE_STAGE, WRITER_ADMISSION_SCOPE,
WRITER_POOL_CHECKOUT_TIMEOUT_STAGE, WRITER_QUEUE_SATURATED_STAGE,
WRITER_TASK_REQUEST_FAILED_STAGE, WRITER_TASK_TERMINATED_STAGE,
};
pub use error_projection::runtime_error_value;
pub use event_cursor_walk::{visit_events_cursor_walk, EventCursorWalkError};
pub use event_page::{
page_budget_exceeded_error, row_exceeds_budget_error, EventReadPageRequest, EventReadPageResult,
};
pub use event_store_guard::EventAttribution;
pub use fusion::FusionStrategy;
pub use graph_traversal::PathNode;
pub use kg_read::KgNeighborRead;
pub use khive_db::{
checkpoint_once, run_checkpoint_task, run_migrations, CheckpointConfig,
CheckpointLifecycleOwner, CheckpointTick, ConnectionPool, StorageBackend,
};
pub use khive_gate::{
classify_operation, is_valid_mailbox_actor_label, split_stamped_label, ActorRef, AllowAllGate,
AuditDecision, AuditEvent, CallerEnrollmentGate, Gate, GateContext, GateDecision, GateError,
GateRef, GateRequest, MailboxPolicyError, MailboxReadGate, Obligation, OperationAccess,
CLASSIFIED_OPERATIONS, OPERATION_CLASSIFIER_VERSION, RUNTIME_STAMPED_ACTOR_KINDS,
};
pub use khive_storage::types::TraversalOptions;
pub use khive_storage::{EventObservation, EventView, ObservationRole, ReferentKind};
pub use khive_types::namespace::Namespace;
pub use mailbox_view::MailboxView;
pub use note_create::{effective_create_tags, EffectiveCreateTags};
pub use objectives::{
AmplifiedDecayAwareSalienceObjective, DecayAwareSalienceObjective, GraphProximityObjective,
MemoryRecallPipeline, NoteCandidate, RerankerObjective, RetrievalCandidate, RrfFusionObjective,
TemporalRecencyObjective, TextRelevanceObjective, VectorSimilarityObjective,
};
#[cfg(any(test, feature = "fault-injection"))]
pub use operations::{
arm_entity_compensation_fail_scoped, arm_fts_fail_many_partial_scoped,
arm_fts_fail_many_scoped, arm_fts_fail_scoped, arm_prefix_resolve_fail_scoped,
arm_rollback_cleanup_fail, arm_vector_fail_after, arm_vector_fail_scoped, FaultInjectionArm,
};
pub use operations::{
base_entity_endpoint_rules, base_entity_rule_allows, endpoint_matches,
hex_prefix_to_uuid_pattern, merge_entry_metadata, uuid_prefix_bounds, ConditionalInsertStage,
EdgeEndpointKind, EntityCreateSpec, LinkSpec, NoteCreateSpec, NoteSearchHit, NoteSearchOutcome,
PostCommitDegradation, QueryResult, Resolved,
};
pub use pack::{
resolve_explicit_namespace, ChannelIngestCapability, DispatchHook, HandlerDef,
IdResolutionMode, IngestAuditStore, InterceptedDispatchResult, KindHook, NoteEmbeddingPolicy,
NoteEmbeddingPolicySpec, NoteKindSpec, NoteLifecycleSpec, NoteUpdateEffect, PackByIdResolver,
PackFactory, PackInstall, PackLoadError, PackMetadataRegistry, PackRegistration, PackRegistry,
PackRuntime, PackSchemaCollisionError, PackSchemaPlan, ParamDef, RequestIdentity, SchemaPlan,
VerbCategory, VerbPresentationPolicy, VerbRegistry, VerbRegistryBuilder, VerifiedActor,
Visibility, AUDIT_PERSISTENCE_SKIPPED_READ_ONLY,
};
pub use params::deser_params;
pub use phase_events::{emit_phase_event, is_benign_shutdown_cancellation};
pub use portability::{ImportSummary, KgArchive};
pub use preference_verification::{LegacyPreferenceVerifier, VerifiedModelNetworkAttachment};
pub use presentation::{
apply_redundancy_drop, micros_to_iso, prepare_format_value, present, present_with_policy,
render_format, rfc3339_to_utc_micros, OutputFormat, PresentationMode, RedundancyScope,
};
pub use reference_resolution::{
resolve_reference, resolve_reference_with_entity_type, 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::{HybridSearchOutcome, RankScoreKind, SearchHit, SearchSignals, SearchSource};
pub use runtime::{
assert_captured_db_anchor_consistent, assert_db_anchor_consistent, expand_tilde,
parse_pack_list, resolve_db_anchor, resolve_project_actor_id, runtime_config_from_khive_config,
BackendId, EntityTypeValidatorFn, KhiveRuntime, NamedVectorIdentity, NamespaceToken,
NoteMutationHookFn, NoteWriteValidatorFn, OpenedDiagnosticBackend, RuntimeConfig,
};
pub use secret_gate::SecretMatch;
pub use telemetry_config::{
TelemetryCarrier, TelemetryChannelConfig, TelemetryConfig, TelemetryFailurePosture,
TelemetryPolicy,
};
pub use validation::{
GraphPatch, GraphSnapshot, RuleFn, RuleId, Severity, ValidationContext, ValidationReport,
ValidationRule, Violation,
};
#[cfg(test)]
mod mount_config_tests;
pub mod mount_config;
pub mod mounted_verb;