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.controller.assembler | |
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 streamDefinition,
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 streamDefinition,
int detailLevel,
List<CompletionProposal> collector) |
Modifier and Type | Method and Description |
---|---|
LinkedList<StreamAppDefinition> |
StreamDefinitionService.getAppDefinitions(StreamDefinition streamDefinition)
Return the linked list of
StreamAppDefinition s associated with the stream definition. |
LinkedList<StreamAppDefinition> |
DefaultStreamDefinitionService.getAppDefinitions(StreamDefinition streamDefinition)
Return the ordered list of application definitions for this stream as a
List . |
org.springframework.cloud.dataflow.core.dsl.StreamNode |
StreamDefinitionService.parse(StreamDefinition streamDefinition)
Parse the given stream definition and return the AST representation of the stream DSL in
StreamNode . |
org.springframework.cloud.dataflow.core.dsl.StreamNode |
DefaultStreamDefinitionService.parse(StreamDefinition streamDefinition)
Use the
StreamParser to retrieve the StreamNode representation of the stream. |
String |
StreamDefinitionService.redactDsl(StreamDefinition streamDefinition) |
String |
DefaultStreamDefinitionService.redactDsl(StreamDefinition streamDefinition) |
Modifier and Type | Method and Description |
---|---|
org.springframework.hateoas.PagedModel<? extends 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<? extends 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.hateoas.server.RepresentationModelAssembler<StreamDefinition,R> |
StreamDefinitionAssemblerProvider.getStreamDefinitionAssembler(List<StreamDefinition> streamDefinitions)
Get the stream definition resource assembler.
|
Modifier and Type | Method and Description |
---|---|
R |
DefaultStreamDefinitionAssembler.instantiateModel(StreamDefinition streamDefinition) |
R |
DefaultStreamDefinitionAssembler.toModel(StreamDefinition stream) |
Modifier and Type | Method and Description |
---|---|
org.springframework.hateoas.server.RepresentationModelAssembler<StreamDefinition,R> |
StreamDefinitionAssemblerProvider.getStreamDefinitionAssembler(List<StreamDefinition> streamDefinitions)
Get the stream definition resource assembler.
|
DefaultStreamDefinitionAssembler |
DefaultStreamDefinitionAssemblerProvider.getStreamDefinitionAssembler(List<StreamDefinition> streamDefinitions) |
Constructor and Description |
---|
DefaultStreamDefinitionAssembler(StreamDefinitionService streamDefinitionService,
StreamService streamService,
List<StreamDefinition> streamDefinitions,
Class<R> classType) |
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,
String platformType)
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 © 2022 Pivotal Software, Inc.. All rights reserved.