kernel/me.ahoo.wow.kernel.memory/InMemoryReservationStore

InMemoryReservationStore

class InMemoryReservationStore(clock: Clock = Clock.systemUTC()) : ReservationStore

A ReservationStore in memory, for tests and samples: one entry per (aggregate type, tenant, namespace, key). Every operation is serialized by one lock; expiry follows clock.

Constructors

constructor(clock: Clock = Clock.systemUTC())

Functions

abandon

open suspend override fun abandon(scope: ReservationScope, key: String, owner: AggregateRef, hold: String): Boolean

confirm

open suspend override fun confirm(scope: ReservationScope, key: String, owner: AggregateRef, version: Int): ConfirmOutcome

find

open suspend override fun find(scope: ReservationScope, key: String): Reservation?

release

open suspend override fun release(scope: ReservationScope, key: String, owner: AggregateRef, version: Int): Boolean

reserve

open suspend override fun reserve(scope: ReservationScope, key: String, owner: AggregateRef, hold: String, ttl: Duration): Reservation?