public class SkipperStreamService extends AbstractStreamService
SkipperStreamDeployer
specific AbstractStreamService
.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_SKIPPER_PACKAGE_VERSION |
streamDefinitionRepository, streamDeployer
Constructor and Description |
---|
SkipperStreamService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator) |
Modifier and Type | Method and Description |
---|---|
String |
convertPropertiesToSkipperYaml(StreamDefinition streamDefinition,
Map<String,String> updateProperties) |
org.springframework.cloud.deployer.spi.app.DeploymentState |
doCalculateStreamState(String name) |
void |
doDeployStream(StreamDefinition streamDefinition,
Map<String,String> deploymentProperties)
Deploy a stream as defined by its stream name and optional deployment properties.
|
Collection<org.springframework.cloud.skipper.domain.Release> |
history(String releaseName)
Get stream's deployment history
|
StreamDeployment |
info(String streamName)
Get stream information including the deployment properties etc.
|
String |
manifest(String name,
int version)
Return a manifest info of a release version.
|
Collection<org.springframework.cloud.skipper.domain.Deployer> |
platformList() |
void |
rollbackStream(String streamName,
int releaseVersion)
Rollback the stream to the previous or a specific version of the stream.
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
state(List<StreamDefinition> streamDefinitions)
Retrieve the deployment state for the given stream definitions.
|
void |
undeployStream(String streamName)
Un-deploys the stream identified by the given stream name.
|
void |
updateStream(String streamName,
String releaseName,
org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier,
Map<String,String> updateProperties) |
void |
updateStream(String streamName,
UpdateStreamRequest updateStreamRequest)
Update the stream using the UpdateStreamRequest.
|
deployStream
public static final String DEFAULT_SKIPPER_PACKAGE_VERSION
public SkipperStreamService(StreamDefinitionRepository streamDefinitionRepository, SkipperStreamDeployer skipperStreamDeployer, AppDeploymentRequestCreator appDeploymentRequestCreator)
public void doDeployStream(StreamDefinition streamDefinition, Map<String,String> deploymentProperties)
doDeployStream
in class AbstractStreamService
streamDefinition
- the stream definition to deploydeploymentProperties
- the deployment properties for the streampublic org.springframework.cloud.deployer.spi.app.DeploymentState doCalculateStreamState(String name)
doCalculateStreamState
in class AbstractStreamService
public void undeployStream(String streamName)
StreamService
streamName
- the name of the stream to un-deploypublic void updateStream(String streamName, UpdateStreamRequest updateStreamRequest)
StreamService
streamName
- the name of the stream to updateupdateStreamRequest
- the UpdateStreamRequest to use during the updatepublic void updateStream(String streamName, String releaseName, org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier, Map<String,String> updateProperties)
public void rollbackStream(String streamName, int releaseVersion)
StreamService
streamName
- the name of the stream to rollbackreleaseVersion
- the version to rollback to (if not specified, rollback to the previous deleted/deployed
release version of the stream.public String convertPropertiesToSkipperYaml(StreamDefinition streamDefinition, Map<String,String> updateProperties)
public Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> state(List<StreamDefinition> streamDefinitions)
StreamService
streamDefinitions
- the list of Stream definitions to calculate the deployment states.public String manifest(String name, int version)
StreamService
name
- the release nameversion
- the release versionpublic Collection<org.springframework.cloud.skipper.domain.Release> history(String releaseName)
StreamService
releaseName
- Stream release namepublic Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()
public StreamDeployment info(String streamName)
StreamService
streamName
- the name of the streamCopyright © 2019 Pivotal Software, Inc.. All rights reserved.