Skip to main content

Crate fathomdb_engine

Crate fathomdb_engine 

Source

Re-exports§

pub use rebuild_actor::RebuildMode;
pub use rebuild_actor::RebuildProgress;
pub use rebuild_actor::RebuildStateRow;

Modules§

rebuild_actor

Structs§

ActionInsert
An action to be inserted in a WriteRequest.
ActionRow
A single action row returned from a query.
AdminHandle
Thread-safe handle to the shared AdminService.
AdminService
Service providing administrative operations (integrity checks, exports, restores, purges).
ChunkInsert
A text chunk to be inserted in a WriteRequest.
EdgeInsert
An edge to be inserted in a WriteRequest.
EdgeRetire
An edge to be retired (soft-deleted) in a WriteRequest.
EngineRuntime
Core engine runtime.
ExecutionCoordinator
Manages a pool of read-only SQLite connections and executes compiled queries.
ExpansionRootRows
Expansion results for a single root node within a grouped query.
ExpansionSlotRows
All expansion results for a single named slot across all roots.
FtsProfile
Stored FTS tokenizer profile for a node kind.
FtsPropertyPathSpec
A single registered property-FTS path with its extraction mode.
FtsPropertySchemaRecord
A registered FTS property projection schema for a node kind.
GroupedQueryRows
Result set from executing a grouped compiled query.
IntegrityReport
Results of a physical and structural integrity check on the database.
LastAccessTouchReport
Report from a last-access touch operation.
LastAccessTouchRequest
Request to update last_accessed_at timestamps for a batch of nodes.
LogicalPurgeReport
Report from permanently purging all rows for a logical ID.
LogicalRestoreReport
Report from restoring a retired logical ID back to active state.
NodeInsert
A node to be inserted in a WriteRequest.
NodeRetire
A node to be retired (soft-deleted) in a WriteRequest.
NodeRow
A single node row returned from a query.
OperationalCollectionRecord
OperationalCompactionReport
OperationalCurrentRow
OperationalFilterField
OperationalHistoryValidationIssue
OperationalHistoryValidationReport
OperationalMutationRow
OperationalPurgeReport
OperationalReadReport
OperationalReadRequest
OperationalRegisterRequest
OperationalRepairReport
OperationalRetentionPlanItem
OperationalRetentionPlanReport
OperationalRetentionRunItem
OperationalRetentionRunReport
OperationalSecondaryIndexField
OperationalSecondaryIndexRebuildReport
OperationalTraceReport
OperationalValidationContract
OperationalValidationField
OptionalProjectionTask
A deferred projection backfill task submitted alongside a write.
ProjectionImpact
Estimated cost of rebuilding a projection (FTS table or vector embeddings).
ProjectionRepairReport
ProjectionService
ProvenanceEvent
A single row from the provenance_events table.
ProvenancePurgeOptions
Options controlling provenance event purging behavior.
ProvenancePurgeReport
Report from a provenance event purge operation.
QueryEmbedderIdentity
Identity metadata for a QueryEmbedder.
QueryPlan
Execution plan returned by ExecutionCoordinator::explain_compiled_read.
QueryRows
Result set from executing a flat (non-grouped) compiled query.
RunInsert
A run to be inserted in a WriteRequest.
RunRow
A single run row returned from a query.
SafeExportManifest
Manifest describing a completed safe export.
SafeExportOptions
Options controlling how a safe database export is performed.
SemanticReport
Results of a semantic consistency check on the graph data.
SharedSqlitePolicy
SkippedEdge
An edge that was skipped during a restore because an endpoint is missing.
SqliteCacheStatus
Cumulative SQLite page-cache counters for a single connection.
StepInsert
A step to be inserted in a WriteRequest.
StepRow
A single step row returned from a query.
TelemetryCounters
Always-on cumulative counters, shared across all engine components.
TelemetrySnapshot
Point-in-time snapshot of all telemetry counters.
TraceReport
Report from tracing all rows associated with a given source_ref.
VecInsert
A vector embedding to attach to an existing chunk.
VecProfile
Stored vector embedding profile (global, kind-agnostic).
VectorRegenerationConfig
Configuration for regenerating vector embeddings.
VectorRegenerationReport
Report from a vector embedding regeneration run.
WriteReceipt
Receipt returned after a successful write transaction.
WriteRequest
A batch of graph mutations to be applied atomically in a single SQLite transaction.
WriterActor
Single-threaded writer that serializes all mutations through one SQLite connection.

Enums§

ChunkPolicy
Policy for handling existing chunks when upserting a node.
EmbedderError
Errors reported by a QueryEmbedder.
EngineError
Top-level error type for all engine operations.
FtsPropertyPathMode
Extraction mode for a single registered FTS property path.
OperationalCollectionKind
OperationalFilterClause
OperationalFilterFieldType
OperationalFilterMode
OperationalFilterValue
OperationalRetentionActionKind
OperationalSecondaryIndexDefinition
OperationalSecondaryIndexValueType
OperationalValidationFieldType
OperationalValidationMode
OperationalWrite
A mutation to an operational collection submitted as part of a write request.
ProjectionTarget
ProvenanceMode
Controls how missing source_ref values are handled at write time.
TelemetryLevel
Controls how much telemetry the engine collects.

Constants§

TOKENIZER_PRESETS
Well-known tokenizer preset names mapped to their FTS5 tokenizer strings.

Traits§

QueryEmbedder
A read-time query embedder.

Functions§

load_vector_regeneration_config
Errors
new_id
Generate a new identifier suitable for use as a row_id, logical_id, or chunk/run/step/action id.
new_row_id
read_db_cache_status
Read cumulative page-cache counters from a SQLite connection.
shared_sqlite_policy
Errors