Package com.github.kagkarlsson.scheduler.testhelper

Class ManualScheduler

java.lang.Object

com.github.kagkarlsson.scheduler.Scheduler

com.github.kagkarlsson.scheduler.testhelper.ManualScheduler

All Implemented Interfaces:

SchedulerClient

public class ManualScheduler
extends Scheduler

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.kagkarlsson.scheduler.SchedulerClient

SchedulerClient.Builder, SchedulerClient.ScheduleOptions, SchedulerClient.SchedulerClientName, SchedulerClient.StandardSchedulerClient

Field Summary

Fields inherited from class com.github.kagkarlsson.scheduler.Scheduler

executeDueStrategy, executor, onStartup, THREAD_PREFIX, TRIGGER_NEXT_BATCH_WHEN_AVAILABLE_THREADS_RATIO

Fields inherited from interface com.github.kagkarlsson.scheduler.SchedulerClient

DEFAULT_BATCH_SIZE

Method Summary

Modifier and Type	Method	Description
SettableClock	getClock()
void	runAnyDueExecutions()
void	runDeadExecutionDetection()
void	setTime(Instant newtime)
void	start()
void	tick(Duration moveClockForward)

Methods inherited from class com.github.kagkarlsson.scheduler.Scheduler

cancel, create, create, detectDeadExecutions, executeDue, executeOnStartup, fetchScheduledExecutions, fetchScheduledExecutions, fetchScheduledExecutionsForTask, fetchScheduledExecutionsForTask, getCurrentlyExecuting, getCurrentlyExecutingWithStaleHeartbeat, getFailingExecutions, getScheduledExecution, getSchedulerState, pause, registerSchedulerListener, reschedule, reschedule, reschedule, resume, schedule, schedule, schedule, schedule, scheduleBatch, scheduleBatch, scheduleIfNotExists, scheduleIfNotExists, stop, triggerCheckForDueExecutions, updateHeartbeatForExecution

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.github.kagkarlsson.scheduler.SchedulerClient

getScheduledExecutions, getScheduledExecutions, getScheduledExecutionsForTask, getScheduledExecutionsForTask, getScheduledExecutionsForTask, scheduleBatch, scheduleBatch

Method Details

getClock

public SettableClock getClock()

tick

public void tick(Duration moveClockForward)

setTime

public void setTime(Instant newtime)

runAnyDueExecutions

public void runAnyDueExecutions()

runDeadExecutionDetection

public void runDeadExecutionDetection()

start

public void start()

Overrides:

start in class Scheduler