Package | Description |
---|---|
org.springframework.cloud.task.batch.listener | |
org.springframework.cloud.task.batch.listener.support | |
org.springframework.cloud.task.batch.partition | |
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 |
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 |
MapTaskBatchDao.saveRelationship(TaskExecution taskExecution,
org.springframework.batch.core.JobExecution jobExecution) |
void |
JdbcTaskBatchDao.saveRelationship(TaskExecution taskExecution,
org.springframework.batch.core.JobExecution jobExecution) |
Modifier and Type | Method and Description |
---|---|
void |
DeployerPartitionHandler.beforeTask(TaskExecution taskExecution) |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutionListener.onTaskEnd(TaskExecution taskExecution)
Invoked before the
TaskExecution has been updated in the TaskRepository
upon task end. |
void |
TaskExecutionListener.onTaskFailed(TaskExecution taskExecution,
Throwable throwable)
Invoked if an uncaught exception occurs during a task execution.
|
void |
TaskExecutionListener.onTaskStartup(TaskExecution taskExecution)
Invoked after the
TaskExecution has been stored in the TaskRepository . |
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.createTaskExecution(String taskName,
Date startTime,
List<String> arguments)
Notifies the repository that a taskExecution needs to be created.
|
TaskExecution |
TaskExplorer.getTaskExecution(long executionId)
Retrieve a
TaskExecution by its id. |
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
|
Modifier and Type | Method and Description |
---|---|
TaskExecution |
TaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments)
Save a new
TaskExecution . |
TaskExecution |
MapTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments) |
TaskExecution |
JdbcTaskExecutionDao.createTaskExecution(String taskName,
Date startTime,
List<String> arguments) |
TaskExecution |
TaskExecutionDao.getTaskExecution(long executionId)
Retrieves a task execution from the task repository.
|
TaskExecution |
MapTaskExecutionDao.getTaskExecution(long executionId) |
TaskExecution |
JdbcTaskExecutionDao.getTaskExecution(long executionId) |
Modifier and Type | Method and Description |
---|---|
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> |
MapTaskExecutionDao.findAll(org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findAll(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> |
MapTaskExecutionDao.findRunningTaskExecutions(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findRunningTaskExecutions(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> |
MapTaskExecutionDao.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable) |
org.springframework.data.domain.Page<TaskExecution> |
JdbcTaskExecutionDao.findTaskExecutionsByName(String taskName,
org.springframework.data.domain.Pageable pageable) |
Map<Long,TaskExecution> |
MapTaskExecutionDao.getTaskExecutions() |
Modifier and Type | Method and Description |
---|---|
TaskExecution |
SimpleTaskRepository.completeTaskExecution(long executionId,
Integer exitCode,
Date endTime,
String exitMessage) |
TaskExecution |
SimpleTaskRepository.createTaskExecution(String taskName,
Date startTime,
List<String> arguments) |
TaskExecution |
SimpleTaskExplorer.getTaskExecution(long executionId) |
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) |
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.