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

ProjectionRun

data class ProjectionRun constructor(val runId: String, val startedAt: Instant, val finishedAt: Instant? = null, val target: String)

A single batch of projection work against a target.

A run groups its ProjectionRecords under a shared runId, giving projection and reconciliation jobs a common run history. This is a plain record; aggregate counts are out of scope.

Constructors

ProjectionRun

constructor(runId: String, startedAt: Instant, finishedAt: Instant? = null, target: String)

Properties

finishedAt

val finishedAt: Instant? = null

When the run finished, or null if still running

runId

val runId: String

Unique identifier for this run (matches ProjectionRecord.runId)

startedAt

val startedAt: Instant

When the run started

target

val target: String

The projection target this run wrote to (e.g. "graph")

Functions

finished

fun finished(at: Instant = Instant.now()): ProjectionRun

Create a copy marked finished at the given instant.