Package com.github.kagkarlsson.scheduler.testhelper

Class TestHelper.ManualSchedulerBuilder

java.lang.Object

com.github.kagkarlsson.scheduler.SchedulerBuilder

com.github.kagkarlsson.scheduler.testhelper.TestHelper.ManualSchedulerBuilder

Enclosing class:

TestHelper

public static class TestHelper.ManualSchedulerBuilder
extends SchedulerBuilder

Field Summary

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

alwaysPersistTimestampInUTC, commitWhenAutocommitDisabled, dataSource, DEFAULT_DELETION_OF_UNRESOLVED_TASKS_DURATION, DEFAULT_FAILURE_LOG_LEVEL, DEFAULT_HEARTBEAT_INTERVAL, DEFAULT_MISSED_HEARTBEATS_LIMIT, DEFAULT_POLLING_INTERVAL, DEFAULT_POLLING_STRATEGY, deleteUnresolvedAfter, dueExecutor, enableImmediateExecution, enablePriority, executionInterceptors, executorService, executorThreads, heartbeatInterval, housekeeperExecutor, jdbcCustomization, knownTasks, LOG_STACK_TRACE_ON_FAILURE, logLevel, logStackTrace, numberOfMissedHeartbeatsBeforeDead, pollingStrategyConfig, registerShutdownHook, schedulerListeners, schedulerName, serializer, SHUTDOWN_MAX_WAIT, shutdownMaxWait, startTasks, statsRegistry, tableName, UPPER_LIMIT_FRACTION_OF_THREADS_FOR_FETCH, waiter

Constructor Summary

Constructors

Constructor	Description
ManualSchedulerBuilder(DataSource dataSource, List<Task<?>> knownTasks)

Method Summary

Modifier and Type	Method	Description
TestHelper.ManualSchedulerBuilder	addSchedulerListener(SchedulerListener listener)
ManualScheduler	build()
TestHelper.ManualSchedulerBuilder	clock(SettableClock clock)
TestHelper.ManualSchedulerBuilder	pollingStrategy(PollingStrategyConfig pollingStrategyConfig)
ManualScheduler	start()
<T extends Task<?> & OnStartup> TestHelper.ManualSchedulerBuilder	startTasks(List<T> startTasks)
TestHelper.ManualSchedulerBuilder	statsRegistry(StatsRegistry statsRegistry)	Deprecated, use addSchedulerListener instead

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

addExecutionInterceptor, alwaysPersistTimestampInUTC, commitWhenAutocommitDisabled, deleteUnresolvedAfter, dueExecutor, enableImmediateExecution, enablePriority, executorService, failureLogging, heartbeatInterval, housekeeperExecutor, jdbcCustomization, missedHeartbeatsLimit, pollingInterval, pollUsingFetchAndLockOnExecute, pollUsingLockAndFetch, registerShutdownHook, schedulerName, serializer, shutdownMaxWait, startTasks, tableName, threads

Methods inherited from class java.lang.Object

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

Constructor Details

ManualSchedulerBuilder

public ManualSchedulerBuilder(DataSource dataSource,
 List<Task<?>> knownTasks)

Method Details

clock

public TestHelper.ManualSchedulerBuilder clock(SettableClock clock)

startTasks

public <T extends Task<?> & OnStartup>
TestHelper.ManualSchedulerBuilder startTasks(List<T> startTasks)

Overrides:

startTasks in class SchedulerBuilder

statsRegistry

public TestHelper.ManualSchedulerBuilder statsRegistry(StatsRegistry statsRegistry)

Description copied from class: SchedulerBuilder

Deprecated, use addSchedulerListener instead

Overrides:

statsRegistry in class SchedulerBuilder

addSchedulerListener

public TestHelper.ManualSchedulerBuilder addSchedulerListener(SchedulerListener listener)

Overrides:

addSchedulerListener in class SchedulerBuilder

pollingStrategy

public TestHelper.ManualSchedulerBuilder pollingStrategy(PollingStrategyConfig pollingStrategyConfig)

build

public ManualScheduler build()

Overrides:

build in class SchedulerBuilder

start

public ManualScheduler start()