Timers

object Timers

How timers are named and derived from the log.

Properties

Link copied to clipboard
const val NOT_EVALUATED: Long

The due time of a timer whose rule this module does not evaluate (cron): never, until the runtime does.

Functions

Link copied to clipboard
fun idOf(ref: AggregateRef, key: String, version: Int): String

The id of the schedule ref set under key in its stream at version: context.aggregate/tenant/id#key@version, each of its names with %, /, # and @ (and the context's .) percent-escaped, so two schedules never share an id (and their slots a request id at one target) however their names join: a#b under c and a under b#c stay apart.

Link copied to clipboard
fun of(stream: EventStreamRecord, set: ScheduleSet, partitions: Int): Timer

The timer set makes, an event of stream, in partitions log partitions: its first slot due as its rule says counted from the commit; a rule the runtime evaluates (cron) is NOT_EVALUATED here, and the runtime gives it its first slot before it writes it. Its causation is the commit (ref@version) in the chain of the command that committed it.

Link copied to clipboard

The owner of an aggregate's timers: the aggregate.