api/me.ahoo.wow.api.ledger

Package-level declarations

Types

class ApplyParkedRetrySpec @InternalWowApi constructor(val subscription: String, val context: String, val aggregate: String, val tenantId: String, val id: String, val maxRetries: Int? = null, val initialBackoff: String? = null, val claimTtl: String? = null) : LedgerCommand

Applies a retry spec to the entry (Ledger.APPLY_RETRY_SPEC, 9.x ApplyRetrySpec): at most maxRetries automatic retries, the first initialBackoff after the failure, each claiming the entry for claimTtl (durations). A member left out keeps the value the entry is retried by now.

Ledger

object Ledger

The failure ledger across services: each service keeps its own ledger, atomic with its checkpoints, and publishes its changes to the ops context, which aggregates them; an operator's action goes back to the owning service.

LedgerCommand

sealed interface LedgerCommand

A system command of the ledger: an operator's action on subscription's entry of the parked aggregate id of tenantId, of the aggregate type aggregate of context. Its fields are plain values, so any operations tool, not only Wow's own, writes its JSON: {"subscription": ..., "context": ..., "aggregate": ..., "tenantId": ..., "id": ...}. A caller sends it as the system command its name says (Ledger.COMMANDS), which a service's call permits must list explicitly (wow.ledger.*).

MarkParkedRecoverable

class MarkParkedRecoverable @InternalWowApi constructor(val subscription: String, val context: String, val aggregate: String, val tenantId: String, val id: String, val recoverable: String) : LedgerCommand

Marks the entry recoverable (Ledger.MARK_RECOVERABLE, 9.x MarkRecoverable): RECOVERABLE, UNRECOVERABLE or UNKNOWN.

RetryParked

class RetryParked @InternalWowApi constructor(val subscription: String, val context: String, val aggregate: String, val tenantId: String, val id: String, val failedAt: Long? = null) : LedgerCommand

Handles the parked aggregate again from where it is parked (Ledger.RETRY).

SkipParked

class SkipParked @InternalWowApi constructor(val subscription: String, val context: String, val aggregate: String, val tenantId: String, val id: String, val failedAt: Long) : LedgerCommand

Resolves the entry without handling what was parked (Ledger.SKIP).