@Configuration @Import(value=org.springframework.cloud.dataflow.completion.CompletionConfiguration.class) @ConditionalOnBean(value={org.springframework.cloud.dataflow.server.config.EnableDataFlowServerConfiguration.Marker.class,org.springframework.cloud.deployer.spi.app.AppDeployer.class,org.springframework.cloud.deployer.spi.task.TaskLauncher.class}) @EnableConfigurationProperties(value={AuthorizationConfig.class,FeaturesProperties.class,VersionInfoProperties.class,MetricsProperties.class}) @ConditionalOnProperty(prefix="dataflow.server", name="enabled", havingValue="true", matchIfMissing=true) @EnableCircuitBreaker public class DataFlowControllerAutoConfiguration extends Object
Constructor and Description |
---|
DataFlowControllerAutoConfiguration() |
Modifier and Type | Method and Description |
---|---|
AboutController |
aboutController(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer,
org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
FeaturesProperties featuresProperties,
VersionInfoProperties versionInfoProperties,
SecurityStateBean securityStateBean) |
org.springframework.analytics.rest.controller.AggregateCounterController |
aggregateCounterController(org.springframework.analytics.metrics.AggregateCounterRepository repository) |
RuntimeAppsController.AppInstanceController |
appInstanceController(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer) |
AppRegistry |
appRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry,
org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader resourceLoader) |
AppRegistryController |
appRegistryController(AppRegistry appRegistry,
ApplicationConfigurationMetadataResolver metadataResolver) |
org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean |
appRegistryFJPFB() |
CompletionController |
completionController(StreamCompletionProvider completionProvider,
TaskCompletionProvider taskCompletionProvider) |
org.springframework.analytics.rest.controller.CounterController |
counterController(org.springframework.boot.actuate.metrics.repository.MetricRepository metricRepository) |
org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader |
delegatingResourceLoader(org.springframework.cloud.deployer.resource.maven.MavenResourceLoader mavenResourceLoader) |
FeaturesController |
featuresController(FeaturesProperties featuresProperties) |
org.springframework.analytics.rest.controller.FieldValueCounterController |
fieldValueCounterController(org.springframework.analytics.metrics.FieldValueCounterRepository repository) |
JobExecutionController |
jobExecutionController(TaskJobService repository) |
JobInstanceController |
jobInstanceController(TaskJobService repository) |
JobStepExecutionController |
jobStepExecutionController(org.springframework.batch.admin.service.JobService service) |
JobStepExecutionProgressController |
jobStepExecutionProgressController(org.springframework.batch.admin.service.JobService service) |
LoginController |
loginController() |
org.springframework.cloud.deployer.resource.maven.MavenProperties |
mavenProperties() |
org.springframework.cloud.deployer.resource.maven.MavenResourceLoader |
mavenResourceLoader(org.springframework.cloud.deployer.resource.maven.MavenProperties properties) |
MetricsController |
metricsController(MetricStore metricStore) |
MetricStore |
metricStore(MetricsProperties metricsProperties) |
RestControllerAdvice |
restControllerAdvice() |
RootController |
rootController(org.springframework.hateoas.EntityLinks entityLinks) |
RuntimeAppsController |
runtimeAppsController(StreamDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer,
MetricStore metricStore) |
org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean |
runtimeAppsStatusFJPFB() |
SecurityController |
securityController(SecurityStateBean securityStateBean) |
StreamDefinitionController |
streamDefinitionController(StreamDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
StreamDeploymentController deploymentController,
org.springframework.cloud.deployer.spi.app.AppDeployer deployer,
AppRegistry appRegistry) |
StreamDeploymentController |
streamDeploymentController(StreamDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
AppRegistry registry,
org.springframework.cloud.deployer.spi.app.AppDeployer deployer,
ApplicationConfigurationMetadataResolver metadataResolver,
CommonApplicationProperties appsProperties) |
TaskDefinitionController |
taskDefinitionController(TaskDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
AppRegistry appRegistry,
TaskService taskService) |
TaskExecutionController |
taskExecutionController(org.springframework.cloud.task.repository.TaskExplorer explorer,
TaskService taskService,
TaskDefinitionRepository taskDefinitionRepository) |
ToolsController |
toolsController() |
UiController |
uiController() |
org.springframework.cloud.deployer.resource.registry.UriRegistry |
uriRegistry(DataSource dataSource) |
@Bean public org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry(DataSource dataSource)
@Bean public AppRegistry appRegistry(org.springframework.cloud.deployer.resource.registry.UriRegistry uriRegistry, org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader resourceLoader)
@Bean public RootController rootController(org.springframework.hateoas.EntityLinks entityLinks)
@Bean public RuntimeAppsController.AppInstanceController appInstanceController(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer)
@Bean public MetricStore metricStore(MetricsProperties metricsProperties)
@Bean @ConditionalOnBean(value=StreamDefinitionRepository.class) public StreamDefinitionController streamDefinitionController(StreamDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, StreamDeploymentController deploymentController, org.springframework.cloud.deployer.spi.app.AppDeployer deployer, AppRegistry appRegistry)
@Bean @ConditionalOnBean(value=StreamDefinitionRepository.class) public StreamDeploymentController streamDeploymentController(StreamDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, AppRegistry registry, org.springframework.cloud.deployer.spi.app.AppDeployer deployer, ApplicationConfigurationMetadataResolver metadataResolver, CommonApplicationProperties appsProperties)
@Bean @ConditionalOnBean(value=StreamDefinitionRepository.class) public RuntimeAppsController runtimeAppsController(StreamDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer, MetricStore metricStore)
@Bean public MetricsController metricsController(MetricStore metricStore)
@Bean @ConditionalOnBean(value=StreamDefinitionRepository.class) @ConditionalOnMissingBean(name="runtimeAppsStatusFJPFB") public org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean runtimeAppsStatusFJPFB()
@Bean public org.springframework.cloud.deployer.resource.maven.MavenResourceLoader mavenResourceLoader(org.springframework.cloud.deployer.resource.maven.MavenProperties properties)
@Bean @ConditionalOnMissingBean(value=org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader.class) public org.springframework.cloud.deployer.resource.support.DelegatingResourceLoader delegatingResourceLoader(org.springframework.cloud.deployer.resource.maven.MavenResourceLoader mavenResourceLoader)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public TaskDefinitionController taskDefinitionController(TaskDefinitionRepository repository, DeploymentIdRepository deploymentIdRepository, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, AppRegistry appRegistry, TaskService taskService)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public TaskExecutionController taskExecutionController(org.springframework.cloud.task.repository.TaskExplorer explorer, TaskService taskService, TaskDefinitionRepository taskDefinitionRepository)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public JobExecutionController jobExecutionController(TaskJobService repository)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public JobStepExecutionController jobStepExecutionController(org.springframework.batch.admin.service.JobService service)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public JobStepExecutionProgressController jobStepExecutionProgressController(org.springframework.batch.admin.service.JobService service)
@Bean @ConditionalOnBean(value=TaskDefinitionRepository.class) public JobInstanceController jobInstanceController(TaskJobService repository)
@Bean @ConditionalOnBean(value=org.springframework.boot.actuate.metrics.repository.MetricRepository.class) public org.springframework.analytics.rest.controller.CounterController counterController(org.springframework.boot.actuate.metrics.repository.MetricRepository metricRepository)
@Bean @ConditionalOnBean(value=org.springframework.analytics.metrics.FieldValueCounterRepository.class) public org.springframework.analytics.rest.controller.FieldValueCounterController fieldValueCounterController(org.springframework.analytics.metrics.FieldValueCounterRepository repository)
@Bean @ConditionalOnBean(value=org.springframework.analytics.metrics.AggregateCounterRepository.class) public org.springframework.analytics.rest.controller.AggregateCounterController aggregateCounterController(org.springframework.analytics.metrics.AggregateCounterRepository repository)
@Bean public CompletionController completionController(StreamCompletionProvider completionProvider, TaskCompletionProvider taskCompletionProvider)
@Bean public ToolsController toolsController()
@Bean @ConditionalOnMissingBean(name="appRegistryFJPFB") public org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean appRegistryFJPFB()
@Bean public AppRegistryController appRegistryController(AppRegistry appRegistry, ApplicationConfigurationMetadataResolver metadataResolver)
@Bean public SecurityController securityController(SecurityStateBean securityStateBean)
@Bean @Conditional(value=OnSecurityEnabledAndOAuth2Disabled.class) public LoginController loginController()
@Bean public FeaturesController featuresController(FeaturesProperties featuresProperties)
@Bean public AboutController aboutController(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, FeaturesProperties featuresProperties, VersionInfoProperties versionInfoProperties, SecurityStateBean securityStateBean)
@Bean public UiController uiController()
@Bean public RestControllerAdvice restControllerAdvice()
@Bean public org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties()
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.