public class SkipperStreamDeployer extends Object implements StreamDeployer
Constructor and Description |
---|
SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
StreamDefinitionRepository streamDefinitionRepository,
AppRegistryService appRegistryService,
ForkJoinPool forkJoinPool) |
Modifier and Type | Method and Description |
---|---|
org.springframework.cloud.deployer.spi.app.DeploymentState |
calculateStreamState(String streamName) |
org.springframework.cloud.skipper.domain.Release |
deployStream(StreamDeploymentRequest streamDeploymentRequest) |
static List<org.springframework.cloud.deployer.spi.app.AppStatus> |
deserializeAppStatus(String platformStatus) |
org.springframework.cloud.deployer.spi.core.RuntimeEnvironmentInfo |
environmentInfo() |
org.springframework.cloud.deployer.spi.app.AppStatus |
getAppStatus(String id) |
org.springframework.data.domain.Page<org.springframework.cloud.deployer.spi.app.AppStatus> |
getAppStatuses(org.springframework.data.domain.Pageable pageable) |
StreamDeployment |
getStreamInfo(String streamName)
Get stream information (including the deployment properties) for the given stream name.
|
Collection<org.springframework.cloud.skipper.domain.Release> |
history(String releaseName) |
String |
manifest(String name) |
String |
manifest(String name,
int version) |
Collection<org.springframework.cloud.skipper.domain.Deployer> |
platformList() |
void |
rollbackStream(String streamName,
int releaseVersion)
Rollback the stream to a specific version
|
Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> |
state(List<StreamDefinition> streamDefinitions) |
void |
undeployStream(String streamName)
Undeploys the stream identified by the given stream name.
|
org.springframework.cloud.skipper.domain.Release |
upgradeStream(String streamName,
org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier,
String configYml)
Update the stream identified by the PackageIdentifier and runtime configuration values.
|
void |
validateAppVersionIsRegistered(org.springframework.cloud.deployer.spi.core.AppDeploymentRequest appDeploymentRequest,
String appVersion) |
public SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient, StreamDefinitionRepository streamDefinitionRepository, AppRegistryService appRegistryService, ForkJoinPool forkJoinPool)
public static List<org.springframework.cloud.deployer.spi.app.AppStatus> deserializeAppStatus(String platformStatus)
public org.springframework.cloud.deployer.spi.app.DeploymentState calculateStreamState(String streamName)
calculateStreamState
in interface StreamDeployer
public Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> state(List<StreamDefinition> streamDefinitions)
state
in interface StreamDeployer
public org.springframework.cloud.skipper.domain.Release deployStream(StreamDeploymentRequest streamDeploymentRequest)
public void validateAppVersionIsRegistered(org.springframework.cloud.deployer.spi.core.AppDeploymentRequest appDeploymentRequest, String appVersion)
public void undeployStream(String streamName)
StreamDeployer
undeployStream
in interface StreamDeployer
streamName
- the name of the stream to un-deploypublic org.springframework.data.domain.Page<org.springframework.cloud.deployer.spi.app.AppStatus> getAppStatuses(org.springframework.data.domain.Pageable pageable) throws ExecutionException, InterruptedException
getAppStatuses
in interface StreamDeployer
ExecutionException
InterruptedException
public org.springframework.cloud.deployer.spi.app.AppStatus getAppStatus(String id)
getAppStatus
in interface StreamDeployer
public org.springframework.cloud.deployer.spi.core.RuntimeEnvironmentInfo environmentInfo()
environmentInfo
in interface StreamDeployer
public StreamDeployment getStreamInfo(String streamName)
StreamDeployer
getStreamInfo
in interface StreamDeployer
streamName
- the name of the streampublic org.springframework.cloud.skipper.domain.Release upgradeStream(String streamName, org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier, String configYml)
streamName
- the name of the stream to upgradepackageIdentifier
- the name of the package in skipperconfigYml
- the YML formatted configuration values to use when upgradingpublic void rollbackStream(String streamName, int releaseVersion)
streamName
- the name of the stream to rollbackreleaseVersion
- the version of the stream to rollback topublic Collection<org.springframework.cloud.skipper.domain.Release> history(String releaseName)
public Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.