@Configuration @Import(value=CompletionConfiguration.class) @ConditionalOnBean(value={org.springframework.cloud.dataflow.server.config.EnableDataFlowServerConfiguration.Marker.class,org.springframework.cloud.deployer.spi.task.TaskLauncher.class}) @EnableConfigurationProperties(value={FeaturesProperties.class,VersionInfoProperties.class,MetricsProperties.class}) @ConditionalOnProperty(prefix="dataflow.server", name="enabled", havingValue="true", matchIfMissing=true) @EnableCircuitBreaker @EntityScan(value="org.springframework.cloud.dataflow.registry.domain") @EnableJpaRepositories(basePackages="org.springframework.cloud.dataflow.registry.repository") @EnableTransactionManagement public class DataFlowControllerAutoConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
static class |
DataFlowControllerAutoConfiguration.AppDeploymentConfiguration |
static class |
DataFlowControllerAutoConfiguration.SkipperDeploymentConfiguration |
Constructor and Description |
---|
DataFlowControllerAutoConfiguration() |
Modifier and Type | Method and Description |
---|---|
AboutController |
aboutController(org.springframework.beans.factory.ObjectProvider<StreamDeployer> streamDeployer,
org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
FeaturesProperties featuresProperties,
VersionInfoProperties versionInfoProperties,
org.springframework.cloud.common.security.support.SecurityStateBean securityStateBean) |
org.springframework.analytics.rest.controller.AggregateCounterController |
aggregateCounterController(org.springframework.analytics.metrics.AggregateCounterRepository repository) |
RuntimeAppsController.AppInstanceController |
appInstanceController(StreamDeployer streamDeployer) |
org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean |
appRegistryFJPFB() |
org.springframework.cloud.common.security.AuthorizationProperties |
authorizationProperties() |
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) |
org.springframework.analytics.rest.controller.FieldValueCounterController |
fieldValueCounterController(org.springframework.analytics.metrics.FieldValueCounterRepository repository) |
org.springframework.cloud.common.security.support.FileSecurityProperties |
fileSecurityProperties() |
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) |
org.springframework.cloud.common.security.support.LdapSecurityProperties |
ldapSecurityProperties() |
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(StreamDeployer streamDeployer,
MetricStore metricStore) |
org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean |
runtimeAppsStatusFJPFB() |
SecurityController |
securityController(org.springframework.cloud.common.security.support.SecurityStateBean securityStateBean) |
org.springframework.cloud.common.security.support.SecurityStateBean |
securityStateBean() |
StreamDefinitionController |
streamDefinitionController(StreamDefinitionRepository repository,
AppRegistryCommon appRegistry,
StreamService streamService) |
StreamDeploymentController |
streamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService) |
AppDeploymentRequestCreator |
streamDeploymentPropertiesUtils(AppRegistryCommon appRegistry,
CommonApplicationProperties commonApplicationProperties,
ApplicationConfigurationMetadataResolver applicationConfigurationMetadataResolver) |
TaskDefinitionController |
taskDefinitionController(TaskDefinitionRepository repository,
DeploymentIdRepository deploymentIdRepository,
org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher,
AppRegistryCommon appRegistry,
TaskService taskService) |
TaskExecutionController |
taskExecutionController(org.springframework.cloud.task.repository.TaskExplorer explorer,
TaskService taskService,
TaskDefinitionRepository taskDefinitionRepository) |
ToolsController |
toolsController() |
UiController |
uiController() |
@Bean public RootController rootController(org.springframework.hateoas.EntityLinks entityLinks)
@Bean @ConditionalOnBean(value={StreamDefinitionRepository.class,StreamDeploymentRepository.class}) public RuntimeAppsController.AppInstanceController appInstanceController(StreamDeployer streamDeployer)
@Bean public MetricStore metricStore(MetricsProperties metricsProperties)
@Bean @ConditionalOnBean(value=StreamDefinitionRepository.class) public StreamDefinitionController streamDefinitionController(StreamDefinitionRepository repository, AppRegistryCommon appRegistry, StreamService streamService)
@Bean @ConditionalOnBean(value={StreamDefinitionRepository.class,StreamDeploymentRepository.class}) public StreamDeploymentController streamDeploymentController(StreamDefinitionRepository repository, StreamService streamService)
@Bean @ConditionalOnMissingBean(name="appRegistryFJPFB") public org.springframework.scheduling.concurrent.ForkJoinPoolFactoryBean appRegistryFJPFB()
@Bean public AppDeploymentRequestCreator streamDeploymentPropertiesUtils(AppRegistryCommon appRegistry, CommonApplicationProperties commonApplicationProperties, ApplicationConfigurationMetadataResolver applicationConfigurationMetadataResolver)
@Bean @ConditionalOnBean(value={StreamDefinitionRepository.class,StreamDeploymentRepository.class}) public RuntimeAppsController runtimeAppsController(StreamDeployer streamDeployer, MetricStore metricStore)
@Bean public MetricsController metricsController(MetricStore metricStore)
@Bean @ConditionalOnBean(value={StreamDefinitionRepository.class,StreamDeploymentRepository.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, AppRegistryCommon 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 public SecurityController securityController(org.springframework.cloud.common.security.support.SecurityStateBean securityStateBean)
@Bean @Conditional(value=org.springframework.cloud.common.security.support.OnSecurityEnabledAndOAuth2Disabled.class) public LoginController loginController()
@Bean public AboutController aboutController(org.springframework.beans.factory.ObjectProvider<StreamDeployer> streamDeployer, org.springframework.cloud.deployer.spi.task.TaskLauncher taskLauncher, FeaturesProperties featuresProperties, VersionInfoProperties versionInfoProperties, org.springframework.cloud.common.security.support.SecurityStateBean securityStateBean)
@Bean public UiController uiController()
@Bean public RestControllerAdvice restControllerAdvice()
@Bean public org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties()
@Bean @ConfigurationProperties(prefix="spring.cloud.dataflow.security.authorization") public org.springframework.cloud.common.security.AuthorizationProperties authorizationProperties()
@Bean @ConditionalOnProperty(name="spring.cloud.dataflow.security.authentication.file.enabled", havingValue="true") @ConfigurationProperties(prefix="spring.cloud.dataflow.security.authentication.file") public org.springframework.cloud.common.security.support.FileSecurityProperties fileSecurityProperties()
@Bean @ConditionalOnProperty(name="spring.cloud.dataflow.security.authentication.ldap.enabled", havingValue="true") @ConfigurationProperties(prefix="spring.cloud.dataflow.security.authentication.ldap") public org.springframework.cloud.common.security.support.LdapSecurityProperties ldapSecurityProperties()
@Bean public org.springframework.cloud.common.security.support.SecurityStateBean securityStateBean()
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.