klokka-core/com.eventslooped.klokka.store

Package-level declarations

Types

data class InMemoryJobSnapshot(val state: JobState, val attempts: Int, val fence: Long, val queue: QueueName, val leaseUntil: Instant?)

Snapshot of a stored job's mutable fields, for tests to assert on without reflection.

InMemoryJobStore

class InMemoryJobStore(clock: Clock = Clock.System, val ephemeral: Boolean = false) : JobStore, PushCapableStore, QueryableStore

An in-process, non-persistent JobStore. Backs single-process usage and the test suite; all state is lost on restart. All time comparisons use the injected clock, which plays the role database time plays for a real backend, so tests can drive time deterministically.

InMemoryScheduleSnapshot

data class InMemoryScheduleSnapshot(val kind: String, val fingerprint: String, val description: String, val nextFireAt: Instant?, val lastFiredAt: Instant?, val fence: Long)

Snapshot of a schedule's mutable fields, for tests to assert on without reflection.