@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.