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,
AppRegistrationAssemblerProvider<? extends AppRegistrationResource> appRegistrationAssemblerProvider) |
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) |
StreamDefinitionAssemblerProvider |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamDefinitionAssemblerProvider(StreamDefinitionService streamDefinitionService,
StreamService streamService) |
StreamDefinitionController |
DataFlowControllerAutoConfiguration.StreamEnabledConfiguration.streamDefinitionController(StreamService streamService,
StreamDefinitionService streamDefinitionService,
AppRegistryService appRegistryService,
StreamDefinitionAssemblerProvider<? extends StreamDefinitionResource> streamDefinitionAssemblerProvider,
AppRegistrationAssemblerProvider<? extends AppRegistrationResource> appRegistrationAssemblerProvider) |
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) |
Modifier and Type | Field and Description |
---|---|
protected StreamDefinitionService |
DefaultStreamDefinitionAssemblerProvider.streamDefinitionService |
protected StreamDefinitionService |
DefaultStreamDefinitionAssembler.streamDefinitionService |
Constructor and Description |
---|
DefaultStreamDefinitionAssembler(StreamDefinitionService streamDefinitionService,
StreamService streamService,
List<StreamDefinition> streamDefinitions,
Class<R> classType) |
DefaultStreamDefinitionAssemblerProvider(StreamDefinitionService streamDefinitionService,
StreamService 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 © 2021 Pivotal Software, Inc.. All rights reserved.