DICE API Documentation/com.embabel.dice.projection.lineage/InMemoryCollectorRecordStore

InMemoryCollectorRecordStore

class InMemoryCollectorRecordStore : CollectorRecordStore

Thread-safe in-memory implementation of CollectorRecordStore.

Intended as a default/stub for demos and tests. Records are append-only and returned in insertion order. Backed by a CopyOnWriteArrayList so reads never block writes.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open override fun all(): List<CollectorRecord>
Link copied to clipboard
open override fun findByProposition(propositionId: String): List<CollectorRecord>

Find all records for a given proposition.

Link copied to clipboard
open override fun findByRun(runId: String): List<CollectorRecord>

Find all records produced by a given run.

Link copied to clipboard
open override fun findRun(runId: String): CollectorRun?

Find the run header for a given run id.

Link copied to clipboard
open override fun record(record: CollectorRecord)

Record a collector outcome.

Link copied to clipboard
open override fun recordRun(run: CollectorRun)

Record a finished run header.

Link copied to clipboard
open override fun runs(): List<CollectorRun>