public abstract class AbstractStreamService extends Object implements StreamService
StreamDeploymentRequest
.
The AbstractStreamService
deployer is agnostic. For deploying streams on
Skipper use the SkipperStreamService
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.
|
protected StreamDeployers |
streamDeployer |
Constructor and Description |
---|
AbstractStreamService(StreamDefinitionRepository streamDefinitionRepository,
StreamDeployers streamDeployer) |
Modifier and Type | Method and Description |
---|---|
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
history, info, manifest, platformList, rollbackStream, state, undeployStream, updateStream
protected final StreamDefinitionRepository streamDefinitionRepository
protected final StreamDeployers streamDeployer
public AbstractStreamService(StreamDefinitionRepository streamDefinitionRepository, StreamDeployers streamDeployer)
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)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.