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

Package-level declarations

Types

object AlwaysCreateReconciler : Reconciler

Reconciler that always returns ReconciliationDecision.CreateNew, the projection counterpart of com.embabel.dice.common.resolver.AlwaysCreateEntityResolver.

CollectorOutcome

enum CollectorOutcome : Enum<CollectorOutcome>

What the collector did to a single proposition during a collection run.

CollectorRecord

data class CollectorRecord constructor(val propositionId: String, val reason: MarkReason, val outcome: CollectorOutcome, val strategyName: String, val runId: String, val at: Instant = Instant.now(), val previousStatus: PropositionStatus? = null, val newStatus: PropositionStatus? = null, val mergedIntoId: String? = null, val undoneAt: Instant? = null)

A record of one proposition being acted upon by a collector during a run.

CollectorRecordStore

interface CollectorRecordStore

Append-only store of CollectorRecords — the audit trail of "what the collector marked or swept, why, and by which strategy".

CollectorRun

data class CollectorRun constructor(val runId: String, val startedAt: Instant, val finishedAt: Instant? = null, val dryRun: Boolean = false)

A record of a collection run — a single batch of mark-and-sweep work over propositions.

InMemoryCollectorRecordStore

class InMemoryCollectorRecordStore : CollectorRecordStore

Thread-safe in-memory implementation of CollectorRecordStore.

InMemoryProjectionRecordStore

class InMemoryProjectionRecordStore : ProjectionRecordStore

Thread-safe in-memory implementation of ProjectionRecordStore.

ProjectionLifecycle

enum ProjectionLifecycle : Enum<ProjectionLifecycle>

Lifecycle state of a single proposition-to-target projection.

ProjectionLineageStaleCascade

class ProjectionLineageStaleCascade(recordStore: ProjectionRecordStore) : DiceEventListener

Listens for proposition status changes and marks the corresponding projection records stale.

ProjectionRecord

data class ProjectionRecord constructor(val propositionId: String, val target: String, val targetRef: String? = null, val lifecycle: ProjectionLifecycle, val runId: String, val at: Instant = Instant.now(), val reason: String? = null, val contextId: String = "")

A record of a single proposition projected to a single target.

ProjectionRecordStore

interface ProjectionRecordStore

Store of ProjectionRecords — the inverse index of "what projected where".

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.

Reconciler

interface Reconciler

Strategy for reconciling a proposition's projection against artifacts that already exist in a target backend, deciding whether to create a new artifact, adopt an existing one, or align with it.

ReconciliationDecision

sealed interface ReconciliationDecision

How a proposition should be projected relative to artifacts that already exist in a target backend: create a new artifact, adopt an existing one, or align with it.

RepositoryBackedReconciler

class RepositoryBackedReconciler(repository: <Error class: unknown class>) : Reconciler

Reconciler that adopts an existing graph relationship when the backing NamedEntityDataRepository can prove the exact projected edge already exists.