InMemoryFailureLedger

A FailureLedger in memory, for tests and samples, keyed by subscription (SubscriptionId) and aggregate. Every operation is serialized by one lock.

Constructors

constructor()

open suspend override fun amend(subscription: SubscriptionId, ref: AggregateRef, amendment: ParkedAmendment): ParkedAggregate?

open suspend override fun count(subscription: SubscriptionId, max: Int): Int

open suspend override fun due(subscription: SubscriptionId, partitions: Collection<Int>, now: Long, after: AggregateRef?, limit: Int): List<ParkedAggregate>

open suspend override fun list(subscription: SubscriptionId, after: AggregateRef?, limit: Int, tenantId: String?): List<ParkedAggregate>

open suspend override fun park(entry: ParkedAggregate): Boolean

open suspend override fun parked(subscription: SubscriptionId, ref: AggregateRef): ParkedAggregate?

open suspend override fun repark(entry: ParkedAggregate, from: Int): Boolean

open suspend override fun resolve(subscription: SubscriptionId, ref: AggregateRef, partition: Int): ParkedAggregate?