public interface StreamService
Modifier and Type | Method and Description |
---|---|
StreamDefinition |
createStream(String streamName,
String dsl,
boolean deploy)
Create a new stream.
|
void |
deleteAll()
Delete all streams, including undeploying.
|
void |
deleteStream(String name)
Delete the stream, including undeloying.
|
void |
deployStream(String name,
Map<String,String> deploymentProperties)
Deploys the stream with the user provided deployment properties.
|
org.springframework.data.domain.Page<StreamDefinition> |
findDefinitionByNameLike(org.springframework.data.domain.Pageable pageable,
String searchName)
Find stream definitions where the findByNameLike parameter
|
StreamDefinition |
findOne(String streamDefinitionName)
Find a stream definition by name.
|
List<StreamDefinition> |
findRelatedStreams(String name,
boolean nested)
Find streams related to the given stream name.
|
StreamDeployment |
info(String streamName)
Get stream information including the deployment properties etc.
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
state(List<StreamDefinition> streamDefinitions)
Retrieve the deployment state for list of stream definitions.
|
void |
undeployStream(String name)
Un-deploys the stream identified by the given stream name.
|
StreamDefinition createStream(String streamName, String dsl, boolean deploy)
streamName
- stream namedsl
- DSL definition for streamdeploy
- if true
, the stream is deployed upon creation (default is
false
)InvalidStreamDefinitionException
- if there are errors in parsing the stream DSL,
resolving the name, or type of applications in the streamvoid deployStream(String name, Map<String,String> deploymentProperties)
name
- the name of the streamdeploymentProperties
- deployment properties to use as passed in from the client.void undeployStream(String name)
name
- the name of the stream to un-deployvoid deleteStream(String name)
name
- the name of the stream to deletevoid deleteAll()
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> state(List<StreamDefinition> streamDefinitions)
streamDefinitions
- the list of Stream definitions to calculate the deployment states.StreamDeployment info(String streamName)
streamName
- the name of the streamList<StreamDefinition> findRelatedStreams(String name, boolean nested)
name
- name of the streamnested
- if should recursively findByNameLike for related stream definitionsorg.springframework.data.domain.Page<StreamDefinition> findDefinitionByNameLike(org.springframework.data.domain.Pageable pageable, String searchName)
searchName
- the findByNameLike parameter to useStreamDefinition findOne(String streamDefinitionName)
streamDefinitionName
- the name of the stream definitionNoSuchStreamDefinitionException
- if the definition can not be found.Copyright © 2018 Pivotal Software, Inc.. All rights reserved.