InMemoryTimerStore

A TimerStore in memory, for tests and samples. Every operation is serialized by one lock.

Constructors

constructor()

open suspend override fun cancel(owner: AggregateRef, key: String, version: Long): Boolean

open suspend override fun cancelAll(owner: AggregateRef, version: Long): Int

open suspend override fun due(partitions: Set<Int>, until: Long, limit: Int): List<Timer>

open suspend override fun find(owner: AggregateRef, key: String): Timer?

open suspend override fun parked(target: AggregateRef): List<Timer>

open suspend override fun put(timer: Timer): Boolean

open suspend override fun settle(changes: List<TimerChange>): Int