@Transactional public class DefaultSkipperStreamService extends AbstractStreamService implements SkipperStreamService
SkipperStreamService
.Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_SKIPPER_PACKAGE_VERSION |
auditRecordService, auditServiceUtils, streamDefinitionRepository, streamValidationService
Constructor and Description |
---|
DefaultSkipperStreamService(StreamDefinitionRepository streamDefinitionRepository,
SkipperStreamDeployer skipperStreamDeployer,
AppDeploymentRequestCreator appDeploymentRequestCreator,
StreamValidationService streamValidationService,
AuditRecordService auditRecordService) |
Modifier and Type | Method and Description |
---|---|
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 list of 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,
boolean force,
List<String> appNames) |
void |
updateStream(String streamName,
UpdateStreamRequest updateStreamRequest)
Update the stream using the UpdateStreamRequest.
|
createStream, createStreamDefinition, deleteAll, deleteStream, deployStream, findDefinitionByNameLike, findOne, findRelatedStreams, validateStream
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createStream, deleteAll, deleteStream, deployStream, findDefinitionByNameLike, findOne, findRelatedStreams, validateStream
public static final String DEFAULT_SKIPPER_PACKAGE_VERSION
public DefaultSkipperStreamService(StreamDefinitionRepository streamDefinitionRepository, SkipperStreamDeployer skipperStreamDeployer, AppDeploymentRequestCreator appDeploymentRequestCreator, StreamValidationService streamValidationService, AuditRecordService auditRecordService)
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
undeployStream
in interface StreamService
streamName
- the name of the stream to un-deploypublic void updateStream(String streamName, UpdateStreamRequest updateStreamRequest)
SkipperStreamService
updateStream
in interface SkipperStreamService
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, boolean force, List<String> appNames)
public void rollbackStream(String streamName, int releaseVersion)
SkipperStreamService
rollbackStream
in interface SkipperStreamService
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 Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> state(List<StreamDefinition> streamDefinitions)
StreamService
state
in interface StreamService
streamDefinitions
- the list of Stream definitions to calculate the deployment states.public String manifest(String name, int version)
SkipperStreamService
manifest
in interface SkipperStreamService
name
- the release nameversion
- the release versionpublic Collection<org.springframework.cloud.skipper.domain.Release> history(String releaseName)
SkipperStreamService
history
in interface SkipperStreamService
releaseName
- Stream release namepublic Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()
platformList
in interface SkipperStreamService
public StreamDeployment info(String streamName)
StreamService
info
in interface StreamService
streamName
- the name of the streamCopyright © 2018 Pivotal Software, Inc.. All rights reserved.