Kronos/kronos/KronosStore

KronosStore

interface KronosStore

Storage abstraction used by Kronos. Implement this interface to add a new backend.

The default implementation is MongoKronosStore from the kronos-mongo artifact. Implementations are responsible for both persistence and any caching strategy they choose.

Functions

abstract suspend fun acquireLock(id: String): KronoJob?

Atomically increment the locks counter on the job with this id. Returns the job or null if the document no longer exists. A null return signals that execution should be aborted.

open fun close()

Release any held resources (connections, scopes). Called on Kronos.shutDown.

abstract suspend fun countByName(name: String): Long

Return the count of jobs with the given name.

abstract suspend fun delete(id: String): KronoJob?

Delete the job with this id. Returns the deleted job (used for callback dispatch) or null if it did not exist.

abstract suspend fun deleteAll(): Boolean

Delete all jobs. Returns true if acknowledged.

abstract suspend fun deleteByName(name: String): Boolean

Delete all jobs with the given name. Returns true if acknowledged.

abstract suspend fun fetchDueJobs(nowMs: Long): List<KronoJob>

Return jobs eligible to run right now: startTime <= nowMs and locks == 0. This query runs every minute — it must be efficient (index-backed).

abstract suspend fun findAll(): List<KronoJob>

Return all scheduled jobs.

abstract suspend fun findById(id: String): KronoJob?

Retrieve a single job by its ID, or null if not found.

abstract suspend fun findByName(name: String): List<KronoJob>

Return all scheduled jobs with the given name.

abstract suspend fun initialize()

Called once at startup — create indexes, run schema migrations, etc.

abstract suspend fun insert(job: KronoJob): KronoJob?

Persist a new job. Returns the inserted job, or null if insertion failed.