KState-Saga/ca.acendas.kstate.saga.journal

Package-level declarations

Types

data class AppendedEntry(val entry: JournalEntry, val entryHash: String? = null)

Result of a successful SagaJournal.append call.

data class ChainHead(val seq: Long, val entryId: String)

Lightweight pointer to the latest entry in a saga run's journal.

Lifecycle phase of a JournalEntry within a saga run.

sealed interface Hashing

Hashing strategy for journal entries — controls whether AppendedEntry.entryHash is populated.

Reference implementation of SagaJournal backed by a ConcurrentHashMap with per-RunId locking.

data class JournalConfig(val hashing: Hashing = Hashing.None, val intentPhaseEnabled: Boolean = true, val bufferSize: Int = SYNCHRONOUS)

Configuration for a SagaJournal instance.

data class JournalEntry(val runId: RunId, val seq: Long, val step: TypedValue?, val phase: EntryPhase, val payload: P, val reverses: Long? = null, val createdAtMillis: Long, val metadata: Map<String, String> = emptyMap())

An immutable record of a single event within a saga run.

sealed interface JournalOutcome<out T>

Library-owned result type for all SagaJournal operations.

Serialization seam for saga payloads stored in a SagaJournal.

value class RunId(val value: String)

Opaque identifier for a single saga run.

Pluggable append-only event log for saga executions.

sealed interface VerifyResult

suspend fun SagaJournal.verify(runId: RunId, fromSeq: Long = 0, toSeq: Long = Long.MAX_VALUE, pageSize: Int = DEFAULT_VERIFY_PAGE_SIZE): JournalOutcome<VerifyResult>

Verifies the tamper-evident hash chain for runId over entries with seq in [fromSeq, toSeq].