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

Class TaskConfiguration

java.lang.Object

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

@Configuration(proxyBeanMethods=false)
 @EnableConfigurationProperties(value={TaskConfigurationProperties.class,CommonApplicationProperties.class,DockerValidatorProperties.class,LocalPlatformProperties.class,ComposedTaskRunnerConfigurationProperties.class})
 @EnableMapRepositories(basePackages="org.springframework.cloud.dataflow.server.job")
 @EnableTransactionManagement
 @Import(value={TaskConfiguration.TaskDeleteServiceConfig.class,org.springframework.cloud.dataflow.schema.service.SchemaServiceConfiguration.class,org.springframework.cloud.dataflow.aggregate.task.AggregateTaskConfiguration.class,AggregateDataFlowTaskConfiguration.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 and Description
static class	TaskConfiguration.TaskDeleteServiceConfig
static class	TaskConfiguration.TaskExecutionServiceConfig
static class	TaskConfiguration.TaskJobServiceConfig

Constructor Summary

Constructors

Constructor and Description
TaskConfiguration()

Method Summary

Modifier and Type	Method and Description
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, AuditRecordService auditRecordService, AppRegistryService registry)
TaskAppDeploymentRequestCreator	taskAppDeploymentRequestCreator(CommonApplicationProperties commonApplicationProperties, ApplicationConfigurationMetadataResolver metadataResolver)
TaskDefinitionReader	taskDefinitionReader(TaskDefinitionRepository taskDefinitionRepository)
TaskExecutionInfoService	taskDefinitionRetriever(AppRegistryService registry, AggregateTaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskConfigurationProperties taskConfigurationProperties, LauncherRepository launcherRepository, List<TaskPlatform> taskPlatforms, ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties)
TaskDeploymentReader	taskDeploymentReader(TaskDeploymentRepository repository)
TaskExecutionCreationService	taskExecutionRepositoryService(TaskRepositoryContainer taskRepositoryContainer, AggregateExecutionSupport aggregateExecutionSupport, TaskDefinitionReader taskDefinitionReader)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskConfiguration

public TaskConfiguration()

Method Detail

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(value={"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,
                                                              AggregateTaskExplorer taskExplorer,
                                                              TaskDefinitionRepository taskDefinitionRepository,
                                                              TaskConfigurationProperties taskConfigurationProperties,
                                                              LauncherRepository launcherRepository,
                                                              List<TaskPlatform> taskPlatforms,
                                                              ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties)

saveTaskService

@Bean
public TaskSaveService saveTaskService(TaskDefinitionRepository taskDefinitionRepository,
                                             AuditRecordService auditRecordService,
                                             AppRegistryService registry)

taskExecutionRepositoryService

@Bean
public TaskExecutionCreationService taskExecutionRepositoryService(TaskRepositoryContainer taskRepositoryContainer,
                                                                         AggregateExecutionSupport aggregateExecutionSupport,
                                                                         TaskDefinitionReader taskDefinitionReader)

taskAppDeploymentRequestCreator

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