Package | Description |
---|---|
org.springframework.cloud.dataflow.server.completion |
Contains classes for the auto-completion support.
|
org.springframework.cloud.dataflow.server.config |
Spring Cloud Data Flow Server configuration classes.
|
org.springframework.cloud.dataflow.server.config.features |
Contains specific features' configuration classes.
|
org.springframework.cloud.dataflow.server.controller |
Spring Cloud Data Flow Server Controllers.
|
org.springframework.cloud.dataflow.server.repository |
Spring Cloud Data Flow Server Repositories.
|
org.springframework.cloud.dataflow.server.service.impl |
Contains Service implementations for the Dataflow Server.
|
org.springframework.cloud.dataflow.server.stream |
Constructor and Description |
---|
TapOnDestinationRecoveryStrategy(StreamDefinitionRepository streamDefinitionRepository) |
Modifier and Type | Method and Description |
---|---|
AppDeployerStreamDeployer |
DataFlowControllerAutoConfiguration.AppDeploymentConfiguration.appDeployerStreamDeployer(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer,
DeploymentIdRepository deploymentIdRepository,
StreamDefinitionRepository streamDefinitionRepository,
StreamDeploymentRepository streamDeploymentRepository,
ForkJoinPool appRegistryFJPFB) |
StreamService |
DataFlowControllerAutoConfiguration.AppDeploymentConfiguration.simpleStreamDeploymentService(StreamDefinitionRepository streamDefinitionRepository,
AppDeployerStreamDeployer appDeployerStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator) |
SkipperAppRegistryController |
DataFlowControllerAutoConfiguration.SkipperDeploymentConfiguration.skipperAppRegistryController(StreamDefinitionRepository streamDefinitionRepository,
StreamService streamService,
AppRegistryService appRegistry,
ApplicationConfigurationMetadataResolver metadataResolver,
ForkJoinPool appRegistryFJPFB,
org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties) |
SkipperStreamDeployer |
DataFlowControllerAutoConfiguration.SkipperDeploymentConfiguration.skipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
StreamDefinitionRepository streamDefinitionRepository,
org.springframework.cloud.skipper.client.SkipperClientProperties skipperClientProperties,
AppRegistryService appRegistryService,
ForkJoinPool runtimeAppsStatusFJPFB) |
SkipperStreamService |
DataFlowControllerAutoConfiguration.SkipperDeploymentConfiguration.skipperStreamDeploymentService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator) |
StreamDefinitionController |
DataFlowControllerAutoConfiguration.streamDefinitionController(StreamDefinitionRepository repository,
AppRegistryCommon appRegistry,
StreamService streamService) |
StreamDeploymentController |
DataFlowControllerAutoConfiguration.AppDeploymentConfiguration.streamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService) |
SkipperStreamDeploymentController |
DataFlowControllerAutoConfiguration.SkipperDeploymentConfiguration.updatableStreamDeploymentController(StreamDefinitionRepository repository,
SkipperStreamService streamService) |
Modifier and Type | Method and Description |
---|---|
StreamDefinitionRepository |
StreamConfiguration.streamDefinitionRepository(DataSource dataSource) |
Modifier and Type | Method and Description |
---|---|
RecoveryStrategy<?> |
StreamConfiguration.tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider,
StreamDefinitionRepository streamDefinitionRepository) |
Constructor and Description |
---|
SkipperAppRegistryController(StreamDefinitionRepository streamDefinitionRepository,
StreamService streamService,
AppRegistryService appRegistryService,
ApplicationConfigurationMetadataResolver metadataResolver,
ForkJoinPool forkJoinPool,
org.springframework.cloud.deployer.resource.maven.MavenProperties mavenProperties) |
SkipperStreamDeploymentController(StreamDefinitionRepository repository,
SkipperStreamService skipperStreamService)
Construct a new UpdatableStreamDeploymentController, given a
StreamDeploymentController and SkipperStreamService |
StreamDefinitionController(StreamDefinitionRepository repository,
AppRegistryCommon appRegistry,
StreamService streamService)
Create a
StreamDefinitionController that delegates
CRUD operations to the provided StreamDefinitionRepository
deployment operations and status computation via StreamService
|
StreamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService)
Create a
StreamDeploymentController that delegates
CRUD operations to the provided StreamDefinitionRepository
deployment operations to the provided AppDeployer via
StreamService
|
Modifier and Type | Class and Description |
---|---|
class |
RdbmsStreamDefinitionRepository
RDBMS implementation of
StreamDefinitionRepository . |
Modifier and Type | Field and Description |
---|---|
protected StreamDefinitionRepository |
AbstractStreamService.streamDefinitionRepository
The repository this controller will use for stream CRUD operations.
|
Constructor and Description |
---|
AbstractStreamService(StreamDefinitionRepository streamDefinitionRepository) |
AppDeployerStreamService(StreamDefinitionRepository streamDefinitionRepository,
AppDeployerStreamDeployer appDeployerStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator) |
DefaultSkipperStreamService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator) |
Constructor and Description |
---|
AppDeployerStreamDeployer(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer,
DeploymentIdRepository deploymentIdRepository,
StreamDefinitionRepository streamDefinitionRepository,
StreamDeploymentRepository streamDeploymentRepository,
ForkJoinPool forkJoinPool) |
SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
StreamDefinitionRepository streamDefinitionRepository,
AppRegistryService appRegistryService,
ForkJoinPool forkJoinPool) |
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.