DICE API Documentation/com.embabel.dice.ingestion/InMemoryIngestionLedger

InMemoryIngestionLedger

class InMemoryIngestionLedger : IngestionLedger

In-memory IngestionLedger backed by a concurrent set of seen hashes.

Suitable for a single process or tests; consumers needing cross-session deduplication supply a durable implementation.

Constructors

constructor()

Functions

forget

open override fun forget(contentHash: String)

Release a previously recorded content hash so it is no longer treated as seen. Used to undo a claim when the work it guarded did not complete, keeping retries of failed content un-deduplicated.

record

open override fun record(contentHash: String)

Record that content with the given hash has been ingested.

recordIfAbsent

open override fun recordIfAbsent(contentHash: String): Boolean

Atomically claim a content hash: record it and report whether the claim was new. This collapses the check-then-record sequence into a single step so concurrent attempts to ingest identical content cannot both pass a separate seen-check before either records.

seen

open override fun seen(contentHash: String): Boolean

Whether content with the given hash has already been recorded.