Package | Description |
---|---|
org.springframework.cloud.dataflow.completion |
Contains classes related to code-completion of stream definitions expressed in the
Spring Cloud Dataflow DSL.
|
org.springframework.cloud.dataflow.core |
Root package of the Spring Cloud Data Flow domain model.
|
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.service.impl |
Contains Service implementations for the Dataflow Server.
|
org.springframework.cloud.dataflow.server.service.impl.validation | |
org.springframework.cloud.dataflow.server.stream |
Modifier and Type | Field and Description |
---|---|
protected StreamDefinitionService |
StacktraceFingerprintingRecoveryStrategy.streamDefinitionService |
Constructor and Description |
---|
PipeIntoOtherAppsExpansionStrategy(AppRegistryService appRegistry,
StreamDefinitionService streamDefinitionService) |
StacktraceFingerprintingRecoveryStrategy(Class<E> exceptionClass,
StreamDefinitionService streamDefinitionService,
String... samples)
Construct a new StacktraceFingerprintingRecoveryStrategy given the parser, and the
expected exception class to be thrown for sample fragments of a stream definition
that is to be parsed.
|
StreamCompletionProvider(List<RecoveryStrategy<?>> completionRecoveryStrategies,
List<ExpansionStrategy> completionExpansionStrategies,
StreamDefinitionService streamDefinitionService) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultStreamDefinitionService
The default implementation of
StreamDefinitionService . |
Constructor and Description |
---|
TapOnDestinationRecoveryStrategy(StreamDefinitionRepository streamDefinitionRepository,
StreamDefinitionService streamDefinitionService) |
Modifier and Type | Method and Description |
---|---|
AppRegistryController |
DataFlowControllerAutoConfiguration.AppRegistryConfiguration.appRegistryController(Optional<StreamDefinitionRepository> streamDefinitionRepository,
Optional<StreamService> streamService,
AppRegistryService appRegistry,
ApplicationConfigurationMetadataResolver metadataResolver,
ForkJoinPool appRegistryFJPFB,
StreamDefinitionService streamDefinitionService) |
SkipperStreamDeployer |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.skipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
StreamDefinitionRepository streamDefinitionRepository,
org.springframework.cloud.skipper.client.SkipperClientProperties skipperClientProperties,
AppRegistryService appRegistryService,
ForkJoinPool runtimeAppsStatusFJPFB,
StreamDefinitionService streamDefinitionService) |
StreamDefinitionController |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamDefinitionController(StreamService streamService,
StreamDefinitionService streamDefinitionService,
AppRegistryService appRegistryService) |
AppDeploymentRequestCreator |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamDeploymentPropertiesUtils(AppRegistryService appRegistry,
CommonApplicationProperties commonApplicationProperties,
ApplicationConfigurationMetadataResolver applicationConfigurationMetadataResolver,
StreamDefinitionService streamDefinitionService) |
StreamService |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator,
StreamValidationService streamValidationService,
org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
StreamDefinitionService streamDefinitionService) |
StreamValidationService |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamValidationService(AppRegistryService appRegistry,
DockerValidatorProperties dockerValidatorProperties,
StreamDefinitionRepository streamDefinitionRepository,
StreamDefinitionService streamDefinitionService) |
StreamDeploymentController |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.updatableStreamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService,
StreamDefinitionService streamDefinitionService) |
Modifier and Type | Method and Description |
---|---|
RecoveryStrategy<?> |
StreamConfiguration.tapOnDestinationExpansionStrategy(StreamCompletionProvider streamCompletionProvider,
StreamDefinitionRepository streamDefinitionRepository,
StreamDefinitionService streamDefinitionService) |
Constructor and Description |
---|
AppRegistryController(Optional<StreamDefinitionRepository> streamDefinitionRepository,
Optional<StreamService> streamService,
AppRegistryService appRegistryService,
ApplicationConfigurationMetadataResolver metadataResolver,
ForkJoinPool forkJoinPool,
StreamDefinitionService streamDefinitionService) |
StreamDefinitionController(StreamService streamService,
StreamDefinitionService streamDefinitionService,
AppRegistryService appRegistryService)
Create a
StreamDefinitionController that delegates to StreamService . |
StreamDeploymentController(StreamDefinitionRepository repository,
StreamService streamService,
StreamDefinitionService streamDefinitionService)
Construct a new UpdatableStreamDeploymentController, given a
StreamDeploymentController and StreamService |
Constructor and Description |
---|
AppDeploymentRequestCreator(AppRegistryService appRegistry,
CommonApplicationProperties commonApplicationProperties,
ApplicationConfigurationMetadataResolver metadataResolver,
StreamDefinitionService streamDefinitionService) |
DefaultStreamService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator,
StreamValidationService streamValidationService,
org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService,
StreamDefinitionService streamDefinitionService) |
Constructor and Description |
---|
DefaultStreamValidationService(AppRegistryService appRegistry,
DockerValidatorProperties dockerValidatorProperties,
StreamDefinitionRepository streamDefinitionRepository,
StreamDefinitionService streamDefinitionService) |
Constructor and Description |
---|
SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
StreamDefinitionRepository streamDefinitionRepository,
AppRegistryService appRegistryService,
ForkJoinPool forkJoinPool,
StreamDefinitionService streamDefinitionService) |
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.