@Transactional public abstract class AbstractStreamService extends Object implements StreamService
StreamDeploymentRequest
.
The AbstractStreamService
deployer is agnostic. For deploying streams on
Skipper use the DefaultSkipperStreamService
and for the AppDeploy stream
deployment use the AppDeployerStreamService
.
Modifier and Type | Field and Description |
---|---|
protected StreamDefinitionRepository |
streamDefinitionRepository
The repository this controller will use for stream CRUD operations.
|
Constructor and Description |
---|
AbstractStreamService(StreamDefinitionRepository streamDefinitionRepository,
AppRegistryCommon appRegistry)
Constructor for implementations of the
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.
|
protected abstract org.springframework.cloud.deployer.spi.app.DeploymentState |
doCalculateStreamState(String name) |
protected abstract void |
doDeployStream(StreamDefinition streamDefinition,
Map<String,String> deploymentProperties) |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
info, state, undeployStream
protected final StreamDefinitionRepository streamDefinitionRepository
public AbstractStreamService(StreamDefinitionRepository streamDefinitionRepository, AppRegistryCommon appRegistry)
StreamService
.streamDefinitionRepository
- the stream definition repository to useappRegistry
- the application registry to usepublic StreamDefinition createStream(String streamName, String dsl, boolean deploy)
StreamService
createStream
in interface StreamService
streamName
- stream namedsl
- DSL definition for streamdeploy
- if true
, the stream is deployed upon creation (default is
false
)public void deployStream(String name, Map<String,String> deploymentProperties)
StreamService
deployStream
in interface StreamService
name
- the name of the streamdeploymentProperties
- deployment properties to use as passed in from the client.protected abstract void doDeployStream(StreamDefinition streamDefinition, Map<String,String> deploymentProperties)
protected abstract org.springframework.cloud.deployer.spi.app.DeploymentState doCalculateStreamState(String name)
public void deleteStream(String name)
StreamService
deleteStream
in interface StreamService
name
- the name of the stream to deletepublic void deleteAll()
StreamService
deleteAll
in interface StreamService
public List<StreamDefinition> findRelatedStreams(String name, boolean nested)
StreamService
findRelatedStreams
in interface StreamService
name
- name of the streamnested
- if should recursively findByNameLike for related stream definitionspublic org.springframework.data.domain.Page<StreamDefinition> findDefinitionByNameLike(org.springframework.data.domain.Pageable pageable, String searchName)
StreamService
findDefinitionByNameLike
in interface StreamService
searchName
- the findByNameLike parameter to usepublic StreamDefinition findOne(String streamDefinitionName)
StreamService
findOne
in interface StreamService
streamDefinitionName
- the name of the stream definitionCopyright © 2019 Pivotal Software, Inc.. All rights reserved.