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.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 |
---|---|
org.springframework.hateoas.PagedResources<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.PagedResources<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 |
---|---|
StreamDefinition |
RdbmsStreamDefinitionRepository.save(StreamDefinition definition) |
Modifier and Type | Method and Description |
---|---|
org.springframework.data.domain.Page<StreamDefinition> |
StreamDefinitionRepository.search(SearchPageable searchPageable) |
Modifier and Type | Method and Description |
---|---|
void |
RdbmsStreamDefinitionRepository.delete(StreamDefinition definition) |
StreamDefinition |
RdbmsStreamDefinitionRepository.save(StreamDefinition definition) |
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 the given 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 the given stream definitions.
|
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamService.state(List<StreamDefinition> streamDefinitions) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
AppDeployerStreamService.state(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
String |
SkipperStreamService.convertPropertiesToSkipperYaml(StreamDefinition streamDefinition,
Map<String,String> updateProperties) |
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) |
void |
SkipperStreamService.doDeployStream(StreamDefinition streamDefinition,
Map<String,String> deploymentProperties)
Deploy a stream as defined by its stream name and optional deployment properties.
|
void |
AppDeployerStreamService.doDeployStream(StreamDefinition streamDefinition,
Map<String,String> deploymentProperties) |
protected abstract void |
AbstractStreamService.doDeployStream(StreamDefinition streamDefinition,
Map<String,String> deploymentProperties) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamService.state(List<StreamDefinition> streamDefinitions) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
AppDeployerStreamService.state(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamDeployer.state(List<StreamDefinition> content) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamDeployer.state(List<StreamDefinition> streamDefinitions) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
AppDeployerStreamDeployer.state(List<StreamDefinition> streamDefinitions) |
Modifier and Type | Method and Description |
---|---|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
StreamDeployer.state(List<StreamDefinition> content) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
SkipperStreamDeployer.state(List<StreamDefinition> streamDefinitions) |
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
AppDeployerStreamDeployer.state(List<StreamDefinition> streamDefinitions) |
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.