Package com.github.kagkarlsson.scheduler

Class SchedulerBuilder

java.lang.Object

com.github.kagkarlsson.scheduler.SchedulerBuilder

Direct Known Subclasses:

TestHelper.ManualSchedulerBuilder

public class SchedulerBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	alwaysPersistTimestampInUTC
protected Clock	clock
protected boolean	commitWhenAutocommitDisabled
protected final DataSource	dataSource
static final Duration	DEFAULT_DELETION_OF_UNRESOLVED_TASKS_DURATION
static final LogLevel	DEFAULT_FAILURE_LOG_LEVEL
static final Duration	DEFAULT_HEARTBEAT_INTERVAL
static final int	DEFAULT_MISSED_HEARTBEATS_LIMIT
static final Duration	DEFAULT_POLLING_INTERVAL
static final PollingStrategyConfig	DEFAULT_POLLING_STRATEGY
protected Duration	deleteUnresolvedAfter
protected ExecutorService	dueExecutor
protected boolean	enableImmediateExecution
protected boolean	enablePriority
protected List<ExecutionInterceptor>	executionInterceptors
protected ExecutorService	executorService
protected int	executorThreads
protected Duration	heartbeatInterval
protected ScheduledExecutorService	housekeeperExecutor
protected JdbcCustomization	jdbcCustomization
protected final List<Task<?>>	knownTasks
static final boolean	LOG_STACK_TRACE_ON_FAILURE
protected LogLevel	logLevel
protected boolean	logStackTrace
protected int	numberOfMissedHeartbeatsBeforeDead
protected PollingStrategyConfig	pollingStrategyConfig
protected boolean	registerShutdownHook
protected List<SchedulerListener>	schedulerListeners
protected SchedulerName	schedulerName
protected Serializer	serializer
static final Duration	SHUTDOWN_MAX_WAIT
protected Duration	shutdownMaxWait
protected final List<OnStartup>	startTasks
protected StatsRegistry	statsRegistry
protected String	tableName
static final double	UPPER_LIMIT_FRACTION_OF_THREADS_FOR_FETCH
protected Waiter	waiter

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
SchedulerBuilder	addExecutionInterceptor(ExecutionInterceptor interceptor)
SchedulerBuilder	addSchedulerListener(SchedulerListener schedulerListener)
SchedulerBuilder	alwaysPersistTimestampInUTC()
Scheduler	build()
SchedulerBuilder	commitWhenAutocommitDisabled(boolean commitWhenAutocommitDisabled)
SchedulerBuilder	deleteUnresolvedAfter(Duration deleteAfter)
SchedulerBuilder	dueExecutor(ExecutorService dueExecutor)
SchedulerBuilder	enableImmediateExecution()
SchedulerBuilder	enablePriority()
SchedulerBuilder	executorService(ExecutorService executorService)
SchedulerBuilder	failureLogging(LogLevel logLevel, boolean logStackTrace)
SchedulerBuilder	heartbeatInterval(Duration duration)
SchedulerBuilder	housekeeperExecutor(ScheduledExecutorService housekeeperExecutor)
SchedulerBuilder	jdbcCustomization(JdbcCustomization jdbcCustomization)
SchedulerBuilder	missedHeartbeatsLimit(int numberOfMissedHeartbeatsBeforeDead)
SchedulerBuilder	pollingInterval(Duration pollingInterval)
SchedulerBuilder	pollUsingFetchAndLockOnExecute(double lowerLimitFractionOfThreads, double executionsPerBatchFractionOfThreads)
SchedulerBuilder	pollUsingLockAndFetch(double lowerLimitFractionOfThreads, double upperLimitFractionOfThreads)
SchedulerBuilder	registerShutdownHook()
SchedulerBuilder	schedulerName(SchedulerName schedulerName)
SchedulerBuilder	serializer(Serializer serializer)
SchedulerBuilder	shutdownMaxWait(Duration shutdownMaxWait)
<T extends Task<?> & OnStartup> SchedulerBuilder	startTasks(List<T> startTasks)
final <T extends Task<?> & OnStartup> SchedulerBuilder	startTasks(T... startTasks)
SchedulerBuilder	statsRegistry(StatsRegistry statsRegistry)	Deprecated.
SchedulerBuilder	tableName(String tableName)
SchedulerBuilder	threads(int numberOfThreads)

Methods inherited from class java.lang.Object

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

Field Details

UPPER_LIMIT_FRACTION_OF_THREADS_FOR_FETCH

public static final double UPPER_LIMIT_FRACTION_OF_THREADS_FOR_FETCH

See Also:

• Constant Field Values

DEFAULT_POLLING_INTERVAL

public static final Duration DEFAULT_POLLING_INTERVAL

DEFAULT_HEARTBEAT_INTERVAL

public static final Duration DEFAULT_HEARTBEAT_INTERVAL

DEFAULT_MISSED_HEARTBEATS_LIMIT

public static final int DEFAULT_MISSED_HEARTBEATS_LIMIT

See Also:

• Constant Field Values

DEFAULT_DELETION_OF_UNRESOLVED_TASKS_DURATION

public static final Duration DEFAULT_DELETION_OF_UNRESOLVED_TASKS_DURATION

SHUTDOWN_MAX_WAIT

public static final Duration SHUTDOWN_MAX_WAIT

DEFAULT_POLLING_STRATEGY

public static final PollingStrategyConfig DEFAULT_POLLING_STRATEGY

DEFAULT_FAILURE_LOG_LEVEL

public static final LogLevel DEFAULT_FAILURE_LOG_LEVEL

LOG_STACK_TRACE_ON_FAILURE

public static final boolean LOG_STACK_TRACE_ON_FAILURE

See Also:

• Constant Field Values

dataSource

protected final DataSource dataSource

knownTasks

protected final List<Task<?>> knownTasks

startTasks

protected final List<OnStartup> startTasks

clock

protected Clock clock

schedulerName

protected SchedulerName schedulerName

executorThreads

protected int executorThreads

waiter

protected Waiter waiter

statsRegistry

protected StatsRegistry statsRegistry

heartbeatInterval

protected Duration heartbeatInterval

serializer

protected Serializer serializer

tableName

protected String tableName

enableImmediateExecution

protected boolean enableImmediateExecution

executorService

protected ExecutorService executorService

dueExecutor

protected ExecutorService dueExecutor

housekeeperExecutor

protected ScheduledExecutorService housekeeperExecutor

deleteUnresolvedAfter

protected Duration deleteUnresolvedAfter

jdbcCustomization

protected JdbcCustomization jdbcCustomization

shutdownMaxWait

protected Duration shutdownMaxWait

commitWhenAutocommitDisabled

protected boolean commitWhenAutocommitDisabled

pollingStrategyConfig

protected PollingStrategyConfig pollingStrategyConfig

logLevel

protected LogLevel logLevel

logStackTrace

protected boolean logStackTrace

enablePriority

protected boolean enablePriority

registerShutdownHook

protected boolean registerShutdownHook

numberOfMissedHeartbeatsBeforeDead

protected int numberOfMissedHeartbeatsBeforeDead

alwaysPersistTimestampInUTC

protected boolean alwaysPersistTimestampInUTC

schedulerListeners

protected List<SchedulerListener> schedulerListeners

executionInterceptors

protected List<ExecutionInterceptor> executionInterceptors

Constructor Details

SchedulerBuilder

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

Method Details

startTasks

@SafeVarargs
public final <T extends Task<?> & OnStartup>
SchedulerBuilder startTasks(T... startTasks)

startTasks

public <T extends Task<?> & OnStartup>
SchedulerBuilder startTasks(List<T> startTasks)

pollingInterval

public SchedulerBuilder pollingInterval(Duration pollingInterval)

heartbeatInterval

public SchedulerBuilder heartbeatInterval(Duration duration)

missedHeartbeatsLimit

public SchedulerBuilder missedHeartbeatsLimit(int numberOfMissedHeartbeatsBeforeDead)

threads

public SchedulerBuilder threads(int numberOfThreads)

executorService

public SchedulerBuilder executorService(ExecutorService executorService)

dueExecutor

public SchedulerBuilder dueExecutor(ExecutorService dueExecutor)

housekeeperExecutor

public SchedulerBuilder housekeeperExecutor(ScheduledExecutorService housekeeperExecutor)

statsRegistry

@Deprecated
public SchedulerBuilder statsRegistry(StatsRegistry statsRegistry)

Deprecated.

Deprecated, use addSchedulerListener instead

addSchedulerListener

public SchedulerBuilder addSchedulerListener(SchedulerListener schedulerListener)

addExecutionInterceptor

public SchedulerBuilder addExecutionInterceptor(ExecutionInterceptor interceptor)

schedulerName

public SchedulerBuilder schedulerName(SchedulerName schedulerName)

serializer

public SchedulerBuilder serializer(Serializer serializer)

tableName

public SchedulerBuilder tableName(String tableName)

enableImmediateExecution

public SchedulerBuilder enableImmediateExecution()

deleteUnresolvedAfter

public SchedulerBuilder deleteUnresolvedAfter(Duration deleteAfter)

jdbcCustomization

public SchedulerBuilder jdbcCustomization(JdbcCustomization jdbcCustomization)

alwaysPersistTimestampInUTC

public SchedulerBuilder alwaysPersistTimestampInUTC()

shutdownMaxWait

public SchedulerBuilder shutdownMaxWait(Duration shutdownMaxWait)

commitWhenAutocommitDisabled

public SchedulerBuilder commitWhenAutocommitDisabled(boolean commitWhenAutocommitDisabled)

pollUsingFetchAndLockOnExecute

public SchedulerBuilder pollUsingFetchAndLockOnExecute(double lowerLimitFractionOfThreads,
 double executionsPerBatchFractionOfThreads)

pollUsingLockAndFetch

public SchedulerBuilder pollUsingLockAndFetch(double lowerLimitFractionOfThreads,
 double upperLimitFractionOfThreads)

failureLogging

public SchedulerBuilder failureLogging(LogLevel logLevel,
 boolean logStackTrace)

registerShutdownHook

public SchedulerBuilder registerShutdownHook()

enablePriority

public SchedulerBuilder enablePriority()

build

public Scheduler build()