@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)
public class TaskConfiguration
extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
TaskConfiguration.TaskDeleteServiceConfig |
static class |
TaskConfiguration.TaskExecutionServiceConfig |
static class |
TaskConfiguration.TaskJobServiceConfig |
| Constructor and Description |
|---|
TaskConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
DeployerConfigurationMetadataResolver |
deployerConfigurationMetadataResolver(TaskConfigurationProperties taskConfigurationProperties) |
org.springframework.batch.core.explore.support.JobExplorerFactoryBean |
jobExplorerFactoryBean(DataSource dataSource) |
org.springframework.batch.core.repository.support.JobRepositoryFactoryBean |
jobRepositoryFactoryBean(DataSource dataSource,
org.springframework.transaction.PlatformTransactionManager platformTransactionManager) |
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) |
SimpleJobServiceFactoryBean |
simpleJobServiceFactoryBean(DataSource dataSource,
org.springframework.batch.core.repository.support.JobRepositoryFactoryBean repositoryFactoryBean,
org.springframework.batch.core.explore.JobExplorer jobExplorer,
org.springframework.transaction.PlatformTransactionManager dataSourceTransactionManager) |
TaskAppDeploymentRequestCreator |
taskAppDeploymentRequestCreator(CommonApplicationProperties commonApplicationProperties,
ApplicationConfigurationMetadataResolver metadataResolver) |
TaskExecutionInfoService |
taskDefinitionRetriever(AppRegistryService registry,
org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
TaskDefinitionRepository taskDefinitionRepository,
TaskConfigurationProperties taskConfigurationProperties,
LauncherRepository launcherRepository,
List<TaskPlatform> taskPlatforms,
ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties) |
TaskExecutionCreationService |
taskExecutionRepositoryService(org.springframework.cloud.task.repository.TaskRepository taskRepository) |
@Bean public DeployerConfigurationMetadataResolver deployerConfigurationMetadataResolver(TaskConfigurationProperties taskConfigurationProperties)
@Bean public LauncherInitializationService launcherInitializationService(LauncherRepository launcherRepository, List<TaskPlatform> platforms, DeployerConfigurationMetadataResolver resolver)
@Profile(value={"local","default"})
@Bean
public TaskPlatform localTaskPlatform(LocalPlatformProperties localPlatformProperties,
@Nullable
org.springframework.cloud.deployer.spi.scheduler.Scheduler localScheduler)
localPlatformProperties - the local platform propertieslocalScheduler - the local scheduler@Bean public TaskExecutionInfoService taskDefinitionRetriever(AppRegistryService registry, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskConfigurationProperties taskConfigurationProperties, LauncherRepository launcherRepository, List<TaskPlatform> taskPlatforms, ComposedTaskRunnerConfigurationProperties composedTaskRunnerConfigurationProperties)
@Bean public TaskSaveService saveTaskService(TaskDefinitionRepository taskDefinitionRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, AppRegistryService registry)
@Bean public TaskExecutionCreationService taskExecutionRepositoryService(org.springframework.cloud.task.repository.TaskRepository taskRepository)
@Bean public TaskAppDeploymentRequestCreator taskAppDeploymentRequestCreator(CommonApplicationProperties commonApplicationProperties, ApplicationConfigurationMetadataResolver metadataResolver)
@Bean public SimpleJobServiceFactoryBean simpleJobServiceFactoryBean(DataSource dataSource, org.springframework.batch.core.repository.support.JobRepositoryFactoryBean repositoryFactoryBean, org.springframework.batch.core.explore.JobExplorer jobExplorer, org.springframework.transaction.PlatformTransactionManager dataSourceTransactionManager) throws Exception
Exception@Bean public org.springframework.batch.core.explore.support.JobExplorerFactoryBean jobExplorerFactoryBean(DataSource dataSource)
@Bean public org.springframework.batch.core.repository.support.JobRepositoryFactoryBean jobRepositoryFactoryBean(DataSource dataSource, org.springframework.transaction.PlatformTransactionManager platformTransactionManager)
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.