Datahike implementation of hive-spi.kg.protocol/IKGStore + IPersistentKGStore
Datahike implementation of hive-spi.kg.protocol/IKGStore + IPersistentKGStore + ITemporalKGStore. Config (db-path/backend/store-id/writer) and the core-norms classpath resource are injected by the host — the store resolves no env/config of its own and carries no hive-mcp dependency.
Upper bound for a Datahike read deref. Dynamic so slow cold-cache workloads
can binding a longer ceiling per call site.
Upper bound for a Datahike read deref. Dynamic so slow cold-cache workloads can `binding` a longer ceiling per call site.
Upper bound for a single Datahike transact! deref. Dynamic so large-batch
writers can binding a longer ceiling per call site.
Upper bound for a single Datahike transact! deref. Dynamic so large-batch writers can `binding` a longer ceiling per call site.
(as-of-db store tx-or-time)Database as of a specific transaction or timestamp.
Database as of a specific transaction or timestamp.
(create-store & [opts])Create a Datahike-backed IKGStore. See make-config for config opts;
:core-norms-resource is a classpath path the host injects for the base KG
norms (nil skips core norms). :read-pool is the ExecutorService reads run
on (default: the process-wide bounded pool, hive-datahike.kg.bounded).
Returns nil on failure (rescue-wrapped).
Create a Datahike-backed IKGStore. See `make-config` for config opts; `:core-norms-resource` is a classpath path the host injects for the base KG norms (nil skips core norms). `:read-pool` is the ExecutorService reads run on (default: the process-wide bounded pool, hive-datahike.kg.bounded). Returns nil on failure (rescue-wrapped).
(health store)Report whether the loaded runtime can open the store and its version provenance.
Report whether the loaded runtime can open the store and its version provenance.
(history-db store)Full history database for temporal queries.
Full history database for temporal queries.
(pull-many store pattern eids)Pull every entity in eids with pattern as ONE read: one task on the
store's bounded read pool, one *read-timeout-ms* deadline for the whole
batch, one snapshot for every entity. Returns a vector aligned with eids
(nil where an eid has no datoms). A batch of N costs one pool task, where N
kg/pull-entity calls cost N, each with its own deadline.
Throws like every other read on timeout, rejection or a failure the reopen does not cure: a batch has no per-entity answer to fake.
Pull every entity in `eids` with `pattern` as ONE read: one task on the store's bounded read pool, one `*read-timeout-ms*` deadline for the whole batch, one snapshot for every entity. Returns a vector aligned with `eids` (nil where an eid has no datoms). A batch of N costs one pool task, where N `kg/pull-entity` calls cost N, each with its own deadline. Throws like every other read on timeout, rejection or a failure the reopen does not cure: a batch has no per-entity answer to fake.
(query-as-of store tx-or-time q & inputs)Query the database as it was at a specific point in time.
Query the database as it was at a specific point in time.
(query-history store q & inputs)Query against the full history database.
Query against the full history database.
(register-norms! resource-path)Register a classpath resource path for addon Datahike norms, applied idempotently on ensure-conn!. Call during addon init, before first store access.
Register a classpath resource path for addon Datahike norms, applied idempotently on ensure-conn!. Call during addon init, before first store access.
(runtime-version-provenance)Versions loaded by the runtime for Datahike's connect-time checks.
Versions loaded by the runtime for Datahike's connect-time checks.
(since-db store tx-or-time)Database with only facts added since a transaction or timestamp.
Database with only facts added since a transaction or timestamp.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |