Uses of Class
com.github.kagkarlsson.scheduler.task.Execution

Packages that use Execution

Package	Description
com.github.kagkarlsson.scheduler
com.github.kagkarlsson.scheduler.event
com.github.kagkarlsson.scheduler.exceptions
com.github.kagkarlsson.scheduler.jdbc
com.github.kagkarlsson.scheduler.stats
com.github.kagkarlsson.scheduler.task

Uses of Execution in com.github.kagkarlsson.scheduler

Methods in com.github.kagkarlsson.scheduler that return Execution

Modifier and Type	Method	Description
Execution	CurrentlyExecuting.getExecution()

Methods in com.github.kagkarlsson.scheduler that return types with arguments of type Execution

Modifier and Type	Method	Description
List<Execution>	TaskRepository.getDeadExecutions(Instant olderThan)
List<Execution>	TaskRepository.getDue(Instant now, int limit)
default Optional<Execution>	TaskRepository.getExecution(TaskInstanceId taskInstance)
Optional<Execution>	TaskRepository.getExecution(String taskName, String taskInstanceId)
List<Execution>	TaskRepository.getExecutionsFailingLongerThan(Duration interval)
List<Execution>	Scheduler.getFailingExecutions(Duration failingAtLeastFor)
List<Execution>	TaskRepository.lockAndFetchGeneric(Instant now, int limit)
List<Execution>	TaskRepository.lockAndGetDue(Instant now, int limit)
Optional<Execution>	TaskRepository.pick(Execution e, Instant timePicked)

Methods in com.github.kagkarlsson.scheduler with parameters of type Execution

Modifier and Type	Method	Description
Optional<Execution>	TaskRepository.pick(Execution e, Instant timePicked)
void	TaskRepository.remove(Execution execution)
Instant	TaskRepository.replace(Execution toBeReplaced, SchedulableInstance<?> newInstance)	Deprecated.
Instant	TaskRepository.replace(Execution toBeReplaced, ScheduledTaskInstance newInstance)
boolean	TaskRepository.reschedule(Execution execution, Instant nextExecutionTime, Object newData, Instant lastSuccess, Instant lastFailure, int consecutiveFailures)
boolean	TaskRepository.reschedule(Execution execution, Instant nextExecutionTime, Instant lastSuccess, Instant lastFailure, int consecutiveFailures)
boolean	TaskRepository.updateHeartbeat(Execution execution, Instant heartbeatTime)
boolean	TaskRepository.updateHeartbeatWithRetry(Execution execution, Instant newHeartbeat, int tries)

Method parameters in com.github.kagkarlsson.scheduler with type arguments of type Execution

Modifier and Type	Method	Description
void	TaskRepository.getScheduledExecutions(ScheduledExecutionsFilter filter, String taskName, Consumer<Execution> consumer)
void	TaskRepository.getScheduledExecutions(ScheduledExecutionsFilter filter, Consumer<Execution> consumer)

Constructors in com.github.kagkarlsson.scheduler with parameters of type Execution

Modifier	Constructor	Description
	CurrentlyExecuting(Execution execution, Clock clock, HeartbeatConfig heartbeatConfig)
	ScheduledExecution(Class<DATA_TYPE> dataClass, Execution execution)

Uses of Execution in com.github.kagkarlsson.scheduler.event

Methods in com.github.kagkarlsson.scheduler.event with parameters of type Execution

Modifier and Type	Method	Description
void	AbstractSchedulerListener.onExecutionDead(Execution execution)
void	SchedulerListener.onExecutionDead(Execution execution)	Scheduler has detected a dead execution.
void	SchedulerListeners.onExecutionDead(Execution execution)

Uses of Execution in com.github.kagkarlsson.scheduler.exceptions

Constructors in com.github.kagkarlsson.scheduler.exceptions with parameters of type Execution

Modifier	Constructor	Description
	ExecutionException(String message, Execution execution)
	ExecutionException(String message, Execution execution, Throwable ex)

Uses of Execution in com.github.kagkarlsson.scheduler.jdbc

Fields in com.github.kagkarlsson.scheduler.jdbc with type parameters of type Execution

Modifier and Type	Field	Description
final Supplier<ResultSetMapper<List<Execution>>>	JdbcTaskRepositoryContext.resultSetMapper

Methods in com.github.kagkarlsson.scheduler.jdbc that return types with arguments of type Execution

Modifier and Type	Method	Description
List<Execution>	JdbcTaskRepository.getDeadExecutions(Instant olderThan)
List<Execution>	JdbcTaskRepository.getDue(Instant now, int limit)
Optional<Execution>	JdbcTaskRepository.getExecution(TaskInstance taskInstance)
Optional<Execution>	JdbcTaskRepository.getExecution(String taskName, String taskInstanceId)
List<Execution>	JdbcTaskRepository.getExecutionsFailingLongerThan(Duration interval)
List<Execution>	JdbcTaskRepository.lockAndFetchGeneric(Instant now, int limit)
List<Execution>	AutodetectJdbcCustomization.lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit, boolean orderByPriority)
List<Execution>	DefaultJdbcCustomization.lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit, boolean orderByPriority)
List<Execution>	JdbcCustomization.lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit, boolean orderByPriority)
List<Execution>	PostgreSqlJdbcCustomization.lockAndFetchSingleStatement(JdbcTaskRepositoryContext ctx, Instant now, int limit, boolean orderByPriority)
List<Execution>	JdbcTaskRepository.lockAndGetDue(Instant now, int limit)
Optional<Execution>	JdbcTaskRepository.pick(Execution e, Instant timePicked)

Methods in com.github.kagkarlsson.scheduler.jdbc with parameters of type Execution

Modifier and Type	Method	Description
Optional<Execution>	JdbcTaskRepository.pick(Execution e, Instant timePicked)
void	JdbcTaskRepository.remove(Execution execution)
Instant	JdbcTaskRepository.replace(Execution toBeReplaced, SchedulableInstance newInstance)
Instant	JdbcTaskRepository.replace(Execution toBeReplaced, ScheduledTaskInstance newInstance)	Instead of doing delete+insert, we allow updating an existing execution will all new fields
boolean	JdbcTaskRepository.reschedule(Execution execution, Instant nextExecutionTime, Object newData, Instant lastSuccess, Instant lastFailure, int consecutiveFailures)
boolean	JdbcTaskRepository.reschedule(Execution execution, Instant nextExecutionTime, Instant lastSuccess, Instant lastFailure, int consecutiveFailures)
boolean	JdbcTaskRepository.updateHeartbeat(Execution e, Instant newHeartbeat)
boolean	JdbcTaskRepository.updateHeartbeatWithRetry(Execution execution, Instant newHeartbeat, int tries)

Method parameters in com.github.kagkarlsson.scheduler.jdbc with type arguments of type Execution

Modifier and Type	Method	Description
void	JdbcTaskRepository.getScheduledExecutions(ScheduledExecutionsFilter filter, String taskName, Consumer<Execution> consumer)
void	JdbcTaskRepository.getScheduledExecutions(ScheduledExecutionsFilter filter, Consumer<Execution> consumer)

Uses of Execution in com.github.kagkarlsson.scheduler.stats

Methods in com.github.kagkarlsson.scheduler.stats with parameters of type Execution

Modifier and Type	Method	Description
void	StatsRegistryAdapter.onExecutionDead(Execution execution)

Uses of Execution in com.github.kagkarlsson.scheduler.task

Methods in com.github.kagkarlsson.scheduler.task that return Execution

Modifier and Type	Method	Description
Execution	ExecutionComplete.getExecution()
Execution	ExecutionContext.getExecution()
Execution	ExecutionFailed.getExecution()
Execution	Execution.updateToPicked(String newPickedBy, Instant newLastHeartbeat)

Methods in com.github.kagkarlsson.scheduler.task with parameters of type Execution

Modifier and Type	Method	Description
static ExecutionComplete	ExecutionComplete.failure(Execution execution, Instant timeStarted, Instant timeDone, Throwable cause)
static ExecutionComplete	ExecutionComplete.success(Execution execution, Instant timeStarted, Instant timeDone)

Constructors in com.github.kagkarlsson.scheduler.task with parameters of type Execution

Modifier	Constructor	Description
	ExecutionContext(SchedulerState schedulerState, Execution execution, SchedulerClient schedulerClient, CurrentlyExecuting currentlyExecuting)
	ExecutionFailed(Execution execution, Instant timeDone, Throwable cause)
	ExecutionOperations(TaskRepository taskRepository, SchedulerListeners schedulerListeners, Execution execution)