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.rest.util |
Contains utilities for the Dataflow REST support.
|
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 |
Contains various Services (Interfaces) that are part of the Dataflow Server.
|
org.springframework.cloud.dataflow.server.service.impl |
Contains Service implementations for the Dataflow Server.
|
org.springframework.cloud.dataflow.server.stream |
Modifier and Type | Method and Description |
---|---|
boolean |
UnfinishedAppNameExpansionStrategy.addProposals(String text,
StreamDefinition streamDefinition,
int detailLevel,
List<CompletionProposal> collector) |
boolean |
PipeIntoOtherAppsExpansionStrategy.addProposals(String text,
StreamDefinition parseResult,
int detailLevel,
List<CompletionProposal> collector) |
boolean |
ExpansionStrategy.addProposals(String text,
StreamDefinition streamDefinition,
int detailLevel,
List<CompletionProposal> collector)
For a given stream DSL text and
StreamDefinition ,
Generate CompletionProposal s that apply (if any) and add them to the
provided collector list
Return true if no other strategies should be applied for the stream DSL
text (this strategy make take the liberty to erase already collected proposals)
|
boolean |
ConfigurationPropertyValueHintExpansionStrategy.addProposals(String text,
StreamDefinition parseResult,
int detailLevel,
List<CompletionProposal> collector) |
Modifier and Type | Method and Description |
---|---|
String |
StreamDefinitionToDslConverter.toDsl(StreamDefinition streamDefinition)
Reverse engineers a
StreamDefinition into a semantically equivalent DSL text representation. |
Modifier and Type | Method and Description |
---|---|
String |
ArgumentSanitizer.sanitizeOriginalStreamDsl(StreamDefinition streamDefinition)
Redacts sensitive property values in a stream.
|
String |
ArgumentSanitizer.sanitizeStream(StreamDefinition streamDefinition)
Redacts sensitive property values in a stream.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.hateoas.PagedModel<StreamDefinitionResource> |
StreamDefinitionController.list(org.springframework.data.domain.Pageable pageable,
String search,
org.springframework.data.web.PagedResourcesAssembler<StreamDefinition> assembler)
Return a page-able list of
StreamDefinitionResource defined streams. |
org.springframework.hateoas.PagedModel<StreamDefinitionResource> |
StreamDefinitionController.listRelated(org.springframework.data.domain.Pageable pageable,
String name,
boolean nested,
org.springframework.data.web.PagedResourcesAssembler<StreamDefinition> assembler)
Return a list of related stream definition resources based on the given stream name.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<StreamDefinition> |
StreamDefinitionRepository.findByNameContains(String name,
org.springframework.data.domain.Pageable pageable) |
Modifier and Type | Method and Description |
---|---|
StreamDefinition |
StreamService.createStream(String streamName,
String dsl,
String description,
boolean deploy)
Create a new stream.
|
StreamDefinition |
StreamService.findOne(String streamDefinitionName)
Find a stream definition by name.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<StreamDefinition> |
StreamService.findDefinitionByNameContains(org.springframework.data.domain.Pageable pageable,
String search)
Find stream definitions where the findByTaskNameContains parameter
|
List<StreamDefinition> |
StreamService.findRelatedStreams(String name,
boolean nested)
Find streams related to the given stream name.
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamService.state(List<StreamDefinition> streamDefinitions)
Retrieve the deployment state for list of stream definitions.
|
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamService.state(List<StreamDefinition> streamDefinitions)
Retrieve the deployment state for list of stream definitions.
|
Modifier and Type | Method and Description |
---|---|
StreamDefinition |
DefaultStreamService.createStream(String streamName,
String dsl,
String description,
boolean deploy)
Create a new stream.
|
StreamDefinition |
DefaultStreamService.createStreamDefinition(String streamName,
String dsl,
String description) |
StreamDefinition |
DefaultStreamService.findOne(String streamDefinitionName)
Find a stream definition by name.
|
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<StreamDefinition> |
DefaultStreamService.findDefinitionByNameContains(org.springframework.data.domain.Pageable pageable,
String search)
Find stream definitions where the findByTaskNameContains parameter
|
List<StreamDefinition> |
DefaultStreamService.findRelatedStreams(String streamName,
boolean nested)
Find streams related to the given stream name.
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
DefaultStreamService.state(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
List<org.springframework.cloud.deployer.spi.core.AppDeploymentRequest> |
AppDeploymentRequestCreator.createRequests(StreamDefinition streamDefinition,
Map<String,String> streamDeploymentProperties)
Create a list of
AppDeploymentRequest s from the provided
StreamDefinition and map of deployment properties. |
List<org.springframework.cloud.deployer.spi.core.AppDeploymentRequest> |
AppDeploymentRequestCreator.createUpdateRequests(StreamDefinition streamDefinition,
Map<String,String> updateProperties) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
DefaultStreamService.state(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamDeployer.streamsStates(List<StreamDefinition> streamDefinitions)
Get the deployment states for a list of stream definitions
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamDeployer.streamsStates(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
void |
SkipperStreamDeployer.validateAppVersionIsRegistered(StreamDefinition streamDefinition,
org.springframework.cloud.deployer.spi.core.AppDeploymentRequest appDeploymentRequest,
String appVersion) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamDeployer.streamsStates(List<StreamDefinition> streamDefinitions)
Get the deployment states for a list of stream definitions
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamDeployer.streamsStates(List<StreamDefinition> streamDefinitions) |
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.