Package | Description |
---|---|
io.spring.configuration | |
org.springframework.cloud.task.batch.listener | |
org.springframework.cloud.task.batch.listener.support | |
org.springframework.cloud.task.batch.partition | |
org.springframework.cloud.task.configuration |
Interfaces for configuring Spring Cloud Task and a default implementations.
|
org.springframework.cloud.task.listener | |
org.springframework.cloud.task.listener.annotation | |
org.springframework.cloud.task.repository | |
org.springframework.cloud.task.repository.dao |
Interface DAO and default implementations for storing and retrieving data for tasks
from a repository.
|
org.springframework.cloud.task.repository.support |
Classes used for setting up and supporting a task repositories.
|
Modifier and Type | Method and Description |
---|---|
void |
TaskRunComponent.init(TaskExecution taskExecution) |
Modifier and Type | Method and Description |
---|---|
void |
TaskBatchExecutionListener.onTaskStartup(TaskExecution taskExecution) |
void |
TaskBatchDao.saveRelationship(TaskExecution taskExecution,
org.springframework.batch.core.JobExecution jobExecution)
Saves the relationship between a task execution and a job execution.
|
Modifier and Type | Method and Description |
---|---|
void |
JdbcTaskBatchDao.saveRelationship(TaskExecution taskExecution,
org.springframework.batch.core.JobExecution jobExecution) |
void |
MapTaskBatchDao.saveRelationship(TaskExecution taskExecution,
org.springframework.batch.core.JobExecution jobExecution) |
Modifier and Type | Method and Description |
---|---|
void |
DeployerPartitionHandler.beforeTask(TaskExecution taskExecution) |
void |
SimpleCommandLineArgsProvider.onTaskStartup(TaskExecution taskExecution) |
Constructor and Description |
---|
SimpleCommandLineArgsProvider(TaskExecution taskExecution) |
Modifier and Type | Method and Description |
---|---|
void |
SingleInstanceTaskListener.lockTask(TaskExecution taskExecution) |
void |
SingleInstanceTaskListener.unlockTaskOnEnd(TaskExecution taskExecution) |
void |
SingleInstanceTaskListener.unlockTaskOnError(TaskExecution taskExecution,
Throwable throwable) |
Modifier and Type | Method and Description |
---|---|
void |
TaskMetrics.onTaskEnd(TaskExecution taskExecution) |
void |
TaskExecutionListener.onTaskEnd(TaskExecution taskExecution)
Invoked before the
TaskExecution has been updated in the
TaskRepository upon task end. |
void |
TaskExecutionListenerSupport.onTaskEnd(TaskExecution taskExecution) |
void |
TaskExecutionListener.onTaskFailed(TaskExecution taskExecution,
Throwable throwable)
Invoked if an uncaught exception occurs during a task execution.
|
void |
TaskExecutionListenerSupport.onTaskFailed(TaskExecution taskExecution,
Throwable throwable) |
void |
TaskMetrics.onTaskStartup(TaskExecution taskExecution) |
void |
TaskExecutionListener.onTaskStartup(TaskExecution taskExecution)
Invoked after the
TaskExecution has been stored in the
TaskRepository . |
void |
TaskExecutionListenerSupport.onTaskStartup(TaskExecution taskExecution) |
Modifier and Type | Method and Description |
---|---|
void |
TaskListenerExecutor.onTaskEnd(TaskExecution taskExecution)
Executes all the methods that have been annotated with @AfterTask.
|
void |
TaskListenerExecutor.onTaskFailed(TaskExecution taskExecution,
Throwable throwable)
Executes all the methods that have been annotated with @FailedTask.
|
void |
TaskListenerExecutor.onTaskStartup(TaskExecution taskExecution)
Executes all the methods that have been annotated with @BeforeTask.
|
Modifier and Type | Method and Description |
---|---|
TaskExecution |
TaskRepository.completeTaskExecution(long executionId,
Integer exitCode,
Date endTime,
String exitMessage)
Notifies the repository that a taskExecution has completed.
|
TaskExecution |
TaskRepository.completeTaskExecution(long executionId,
Integer exitCode,
Date endTime,
String exitMessage,
String errorMessage)
Notifies the repository that a taskExecution has completed.
|
TaskExecution |
TaskRepository.createTaskExecution()
Creates an empty TaskExecution with just an id provided.
|
TaskExecution |
TaskRepository.createTaskExecution(String name)
Creates an empty TaskExecution with just an id and name provided.
|
TaskExecution |
TaskRepository.createTaskExecution(TaskExecution taskExecution)
Notifies the repository that a taskExecution needs to be created.
|
TaskExecution |
TaskExplorer.getLatestTaskExecutionForTaskName(String taskName)
Returns the latest task execution for a given task name.
|
TaskExecution |
TaskExplorer.getTaskExecution(long executionId)
Retrieve a
TaskExecution by its id. |
TaskExecution |
TaskRepository.startTaskExecution(long executionid,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId)
Notifies the repository that a taskExecution has has started.
|
TaskExecution |
TaskRepository.startTaskExecution(long executionid,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId)
Notifies the repository that a taskExecution has has started.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<TaskExecution> |
TaskExplorer.findAll(org.springframework.data.domain.Pageable pageable)
Retrieves all the task executions within the pageable constraints sorted by start
date descending, taskExecution id descending.
|
org.springframework.data.domain.Page<TaskExecution> |
TaskExplorer.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable)
Retrieve a collection of taskExecutions that have the task name provided.
|
org.springframework.data.domain.Page<TaskExecution> |
TaskExplorer.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable)
Get a collection/page of executions.
|
List<TaskExecution> |
TaskExplorer.getLatestTaskExecutionsByTaskNames(String... taskNames)
Returns a
List of the latest TaskExecution for 1 or more task
names. |
Modifier and Type | Method and Description |
---|---|
TaskExecution |
TaskRepository.createTaskExecution(TaskExecution taskExecution)
Notifies the repository that a taskExecution needs to be created.
|
Modifier and Type | Method and Description |
---|---|
TaskExecution |
MapTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId) |
TaskExecution |
TaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId)
Save a new
TaskExecution . |
TaskExecution |
JdbcTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId) |
TaskExecution |
MapTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId) |
TaskExecution |
TaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId)
Save a new
TaskExecution . |
TaskExecution |
JdbcTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId) |
TaskExecution |
MapTaskExecutionDao.getLatestTaskExecutionForTaskName(String taskName) |
TaskExecution |
TaskExecutionDao.getLatestTaskExecutionForTaskName(String taskName)
Returns the latest task execution for a given task name.
|
TaskExecution |
JdbcTaskExecutionDao.getLatestTaskExecutionForTaskName(String taskName) |
TaskExecution |
MapTaskExecutionDao.getTaskExecution(long executionId) |
TaskExecution |
TaskExecutionDao.getTaskExecution(long executionId)
Retrieves a task execution from the task repository.
|
TaskExecution |
JdbcTaskExecutionDao.getTaskExecution(long executionId) |
TaskExecution |
MapTaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionid) |
TaskExecution |
TaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId)
Update and existing
TaskExecution to mark it as started. |
TaskExecution |
JdbcTaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId) |
TaskExecution |
MapTaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionid,
Long parentExecutionId) |
TaskExecution |
TaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId)
Update and existing
TaskExecution to mark it as started. |
TaskExecution |
JdbcTaskExecutionDao.startTaskExecution(long executionId,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId) |
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<TaskExecution> |
MapTaskExecutionDao.findAll(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
TaskExecutionDao.findAll(org.springframework.data.domain.Pageable pageable)
Retrieves all the task executions within the pageable constraints.
|
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findAll(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
MapTaskExecutionDao.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
TaskExecutionDao.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable)
Retrieves a set of task executions that are running for a taskName.
|
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
MapTaskExecutionDao.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
TaskExecutionDao.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable)
Retrieves a subset of task executions by task name, start location and size.
|
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable) |
List<TaskExecution> |
MapTaskExecutionDao.getLatestTaskExecutionsByTaskNames(String... taskNames) |
List<TaskExecution> |
TaskExecutionDao.getLatestTaskExecutionsByTaskNames(String... taskNames)
Returns a
List of the latest TaskExecution for 1 or more task
names. |
List<TaskExecution> |
JdbcTaskExecutionDao.getLatestTaskExecutionsByTaskNames(String... taskNames) |
Map<Long,TaskExecution> |
MapTaskExecutionDao.getTaskExecutions() |
Modifier and Type | Method and Description |
---|---|
TaskExecution |
SimpleTaskRepository.completeTaskExecution(long executionId,
Integer exitCode,
Date endTime,
String exitMessage) |
TaskExecution |
SimpleTaskRepository.completeTaskExecution(long executionId,
Integer exitCode,
Date endTime,
String exitMessage,
String errorMessage) |
TaskExecution |
SimpleTaskRepository.createTaskExecution() |
TaskExecution |
SimpleTaskRepository.createTaskExecution(String name) |
TaskExecution |
SimpleTaskRepository.createTaskExecution(TaskExecution taskExecution) |
TaskExecution |
SimpleTaskExplorer.getLatestTaskExecutionForTaskName(String taskName) |
TaskExecution |
SimpleTaskExplorer.getTaskExecution(long executionId) |
TaskExecution |
SimpleTaskRepository.startTaskExecution(long executionid,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId) |
TaskExecution |
SimpleTaskRepository.startTaskExecution(long executionid,
String taskName,
Date startTime,
List<String> arguments,
String externalExecutionId,
Long parentExecutionId) |
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<TaskExecution> |
SimpleTaskExplorer.findAll(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
SimpleTaskExplorer.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
SimpleTaskExplorer.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable) |
List<TaskExecution> |
SimpleTaskExplorer.getLatestTaskExecutionsByTaskNames(String... taskNames) |
Modifier and Type | Method and Description |
---|---|
TaskExecution |
SimpleTaskRepository.createTaskExecution(TaskExecution taskExecution) |
Copyright © 2021 Pivotal Software, Inc.. All rights reserved.