Moves the time on by duration: each instance runs the slots then due, and the handlers of its job get each tick, in order. expect checks what the handlers did with all of them together, and fails when no slot was due; without it, the step fails only when a handler or a job's command throws.

answerCalls

fun answerCalls(answer: (Command<*>) -> CommandResult)

Answers each synchronous call a handler makes with what answer returns, as ProcessorSpec.answerCalls does.

disable

fun disable(job: String, tenantId: String = DEFAULT_TENANT, partition: Int? = null)

Disables job's instance in tenantId.

enable

fun enable(job: String, tenantId: String = DEFAULT_TENANT, rule: JobRule? = null, partition: Int? = null)

Enables the instance of job in tenantId (the default tenant for a SYSTEM or a SHARDED job) by its default rule under rule, as wow.schedule.Enable does; the instance of partition for a SHARDED job. Fails when the instance refuses it.

givenQueries

fun givenQueries(queries: NodeQueryApi)

Serves the handlers' reads from queries, as ProcessorSpec.givenQueries does.

instanceOf

fun instanceOf(job: String, tenantId: String = DEFAULT_TENANT, partition: Int? = null): JobState?

The state of job's instance in tenantId, or null when it was never enabled.

reschedule

fun reschedule(job: String, tenantId: String = DEFAULT_TENANT, rule: JobRule? = null, partition: Int? = null)

Overrides the rule of job's instance in tenantId with rule, null to follow the default again.

whenTick

fun whenTick(tick: ScheduleTick, expect: ProcessorExpectations.() -> Unit = {})

Hands tick to the handlers of its job directly, as the runtime would after its instance committed it, and checks what they did in expect.