Package org.springframework.cloud.dataflow.server.config.features

Class TaskConfiguration

java.lang.Object

org.springframework.cloud.dataflow.server.config.features.TaskConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties({TaskConfigurationProperties.class,CommonApplicationProperties.class,DockerValidatorProperties.class,LocalPlatformProperties.class,ComposedTaskRunnerConfigurationProperties.class})
@EnableMapRepositories(basePackages="org.springframework.cloud.dataflow.server.job")
@EnableTransactionManagement
@Import({TaskDeleteServiceConfig.class,DataflowTaskExplorerConfiguration.class,DataFlowTaskConfiguration.class})
public class TaskConfiguration
extends Object

Author:

Thomas Risberg, Janne Valkealahti, Glenn Renfro, Michael Minella, Ilayaperumal Gopinathan, Gunnar Hillert, Christian Tzolov, David Turanski, Corneil du Plessis

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TaskConfiguration.TaskDeleteServiceConfig
static class	TaskConfiguration.TaskExecutionServiceConfig
static class	TaskConfiguration.TaskJobServiceConfig

Constructor Summary

Constructors

Constructor	Description
TaskConfiguration()

Method Summary

Modifier and Type	Method	Description
DataflowTaskExecutionQueryDao	dataflowTaskExecutionQueryDao(DataSource dataSource)
DeployerConfigurationMetadataResolver	deployerConfigurationMetadataResolver(TaskConfigurationProperties taskConfigurationProperties)
LauncherInitializationService	launcherInitializationService(LauncherRepository launcherRepository, List<TaskPlatform> platforms, DeployerConfigurationMetadataResolver resolver)
TaskPlatform	localTaskPlatform(LocalPlatformProperties localPlatformProperties, org.springframework.cloud.deployer.spi.scheduler.Scheduler localScheduler)	The default profile is active when no other profiles are active.
TaskSaveService	saveTaskService(TaskDefinitionRepository taskDefinitionRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, AppRegistryService registry)
TaskAppDeploymentRequestCreator	taskAppDeploymentRequestCreator(CommonApplicationProperties commonApplicationProperties, ApplicationConfigurationMetadataResolver metadataResolver)
TaskDefinitionReader	taskDefinitionReader(TaskDefinitionRepository taskDefinitionRepository)
TaskExecutionInfoService	taskDefinitionRetriever(AppRegistryService registry, DataflowTaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskConfigurationProperties taskConfigurationProperties, LauncherRepository launcherRepository, List<TaskPlatform> taskPlatforms, ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties)
TaskDeploymentReader	taskDeploymentReader(TaskDeploymentRepository repository)
TaskExecutionCreationService	taskExecutionRepositoryService(org.springframework.cloud.task.repository.TaskRepository taskRepository)
org.springframework.cloud.task.repository.TaskRepository	taskRepository(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

TaskConfiguration

public TaskConfiguration()

Method Details

taskDefinitionReader

@Bean
@ConditionalOnMissingBean
public TaskDefinitionReader taskDefinitionReader(TaskDefinitionRepository taskDefinitionRepository)

taskDeploymentReader

@Bean
@ConditionalOnMissingBean
public TaskDeploymentReader taskDeploymentReader(TaskDeploymentRepository repository)

deployerConfigurationMetadataResolver

@Bean
public DeployerConfigurationMetadataResolver deployerConfigurationMetadataResolver(TaskConfigurationProperties taskConfigurationProperties)

launcherInitializationService

@Bean
public LauncherInitializationService launcherInitializationService(LauncherRepository launcherRepository,
 List<TaskPlatform> platforms,
 DeployerConfigurationMetadataResolver resolver)

localTaskPlatform

@Profile({"local","default"})
@Bean
public TaskPlatform localTaskPlatform(LocalPlatformProperties localPlatformProperties,
 @Nullable
 org.springframework.cloud.deployer.spi.scheduler.Scheduler localScheduler)

The default profile is active when no other profiles are active. This is configured so that several tests will pass without having to explicitly enable the local profile.

Parameters:

localPlatformProperties - the local platform properties

localScheduler - the local scheduler

Returns:

the task platform

taskDefinitionRetriever

@Bean
public TaskExecutionInfoService taskDefinitionRetriever(AppRegistryService registry,
 DataflowTaskExplorer taskExplorer,
 TaskDefinitionRepository taskDefinitionRepository,
 TaskConfigurationProperties taskConfigurationProperties,
 LauncherRepository launcherRepository,
 List<TaskPlatform> taskPlatforms,
 ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties)

saveTaskService

@Bean
public TaskSaveService saveTaskService(TaskDefinitionRepository taskDefinitionRepository,
 org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
 AppRegistryService registry)

taskExecutionRepositoryService

@Bean
public TaskExecutionCreationService taskExecutionRepositoryService(org.springframework.cloud.task.repository.TaskRepository taskRepository)

taskAppDeploymentRequestCreator

@Bean
public TaskAppDeploymentRequestCreator taskAppDeploymentRequestCreator(CommonApplicationProperties commonApplicationProperties,
 ApplicationConfigurationMetadataResolver metadataResolver)

taskRepository

@Bean
public org.springframework.cloud.task.repository.TaskRepository taskRepository(DataSource dataSource)

dataflowTaskExecutionQueryDao

@Bean
public DataflowTaskExecutionQueryDao dataflowTaskExecutionQueryDao(DataSource dataSource)