@Configuration @EnableConfigurationProperties(value={TaskConfigurationProperties.class,CommonApplicationProperties.class,DockerValidatorProperties.class,LocalPlatformProperties.class}) @EnableMapRepositories(basePackages="org.springframework.cloud.dataflow.server.job") @EnableTransactionManagement public class TaskConfiguration extends Object
Constructor and Description |
---|
TaskConfiguration() |
Modifier and Type | Method and Description |
---|---|
TaskDeleteService |
deleteTaskService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
LauncherRepository launcherRepository,
TaskDefinitionRepository taskDefinitionRepository,
TaskDeploymentRepository taskDeploymentRepository,
org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
DataflowTaskExecutionDao dataflowTaskExecutionDao,
DataflowJobExecutionDao dataflowJobExecutionDao,
DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao) |
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) |
TaskExecutionCreationService |
taskExecutionRepositoryService(org.springframework.cloud.task.repository.TaskRepository taskRepository) |
TaskJobService |
taskJobExecutionRepository(JobService service,
org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
TaskDefinitionRepository taskDefinitionRepository,
TaskExecutionService taskExecutionService) |
TaskExecutionService |
taskService(LauncherRepository launcherRepository,
org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
org.springframework.cloud.task.repository.TaskRepository taskRepository,
TaskExecutionInfoService taskExecutionInfoService,
TaskDeploymentRepository taskDeploymentRepository,
TaskExecutionCreationService taskExecutionRepositoryService,
TaskAppDeploymentRequestCreator taskAppDeploymentRequestCreator,
org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
DataflowTaskExecutionDao dataflowTaskExecutionDao,
DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao,
org.springframework.cloud.common.security.core.support.OAuth2TokenUtilsService oauth2TokenUtilsService,
TaskSaveService taskSaveService) |
@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)
@Bean public TaskDeleteService deleteTaskService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer, LauncherRepository launcherRepository, TaskDefinitionRepository taskDefinitionRepository, TaskDeploymentRepository taskDeploymentRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, DataflowTaskExecutionDao dataflowTaskExecutionDao, DataflowJobExecutionDao dataflowJobExecutionDao, DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao)
@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 TaskExecutionService taskService(LauncherRepository launcherRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService, org.springframework.cloud.task.repository.TaskRepository taskRepository, TaskExecutionInfoService taskExecutionInfoService, TaskDeploymentRepository taskDeploymentRepository, TaskExecutionCreationService taskExecutionRepositoryService, TaskAppDeploymentRequestCreator taskAppDeploymentRequestCreator, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, DataflowTaskExecutionDao dataflowTaskExecutionDao, DataflowTaskExecutionMetadataDao dataflowTaskExecutionMetadataDao, @Nullable org.springframework.cloud.common.security.core.support.OAuth2TokenUtilsService oauth2TokenUtilsService, TaskSaveService taskSaveService)
@Bean public TaskJobService taskJobExecutionRepository(JobService service, org.springframework.cloud.task.repository.TaskExplorer taskExplorer, TaskDefinitionRepository taskDefinitionRepository, TaskExecutionService taskExecutionService)
@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 © 2020 Pivotal Software, Inc.. All rights reserved.