DICE API Documentation/com.embabel.dice.storage/DrivineChunkHistoryStore

DrivineChunkHistoryStore

class DrivineChunkHistoryStore(graphObjectManager: <Error class: unknown class>, persistenceManager: <Error class: unknown class>) : ChunkHistoryStore

Drivine / Neo4j ChunkHistoryStore: tracks processed source chunks (:ProcessedChunk) for incremental analysis — dedup by content hash and per-source resume bookmarks. The graph implementation of the dice-core SPI; ships here alongside DrivinePropositionRepository so a consumer needs no hand-rolled store.

Constructors

constructor(graphObjectManager: <Error class: unknown class>, persistenceManager: <Error class: unknown class>)

Functions

clearAll

open fun clearAll()

Remove all history across every context. Default no-op for backward compatibility.

clearByContext

open override fun clearByContext(contextId: <Error class: unknown class>)

Remove all history for the given context. Default no-op for backward compatibility.

getLastBookmark

open override fun getLastBookmark(key: BookmarkKey): AnalysisBookmark?

Most-recently-processed chunk for the source. A bare @NodeFragment has no generated query DSL, so the "latest by processedAt" pick is a small parameterized Cypher returning the id; the node itself is then loaded via the high-level API (correct temporal deserialization).

isProcessed

open override fun isProcessed(key: HashKey): Boolean

Node id is scoped by context so the same content hash can exist in different contexts.

recordProcessed

open override fun recordProcessed(record: ProcessedChunkRecord)

Record that a chunk has been processed.