org.springframework.cloud.dataflow.server.stream

Class SkipperStreamDeployer

java.lang.Object

org.springframework.cloud.dataflow.server.stream.SkipperStreamDeployer

All Implemented Interfaces:

StreamDeployer

public class SkipperStreamDeployer
extends Object
implements StreamDeployer

Delegates to Skipper to deploy the stream.

Author:

Mark Pollack, Ilayaperumal Gopinathan, Soby Chacko, Glenn Renfro, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient, StreamDefinitionRepository streamDefinitionRepository, AppRegistryService appRegistryService, ForkJoinPool forkJoinPool)

Method Summary

Modifier and Type	Method and Description
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 appDeploymentId) Gets runtime application status
org.springframework.data.domain.Page<org.springframework.cloud.deployer.spi.app.AppStatus>	getAppStatuses(org.springframework.data.domain.Pageable pageable) Returns application statuses of all deployed applications
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>	streamsStates(List<StreamDefinition> streamDefinitions) Get the deployment states for a list of stream definitions
org.springframework.cloud.deployer.spi.app.DeploymentState	streamState(String streamName) Get the deployment state of a stream.
void	undeployStream(String streamName)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SkipperStreamDeployer

public SkipperStreamDeployer(org.springframework.cloud.skipper.client.SkipperClient skipperClient,
                             StreamDefinitionRepository streamDefinitionRepository,
                             AppRegistryService appRegistryService,
                             ForkJoinPool forkJoinPool)

Method Detail

deserializeAppStatus

public static List<org.springframework.cloud.deployer.spi.app.AppStatus> deserializeAppStatus(String platformStatus)

streamState

public org.springframework.cloud.deployer.spi.app.DeploymentState streamState(String streamName)

Description copied from interface: StreamDeployer

Get the deployment state of a stream. Stream state is computed from the deployment states of its apps.

Specified by:

streamState in interface StreamDeployer

Parameters:

streamName - stream name

Returns:

the deployment status

streamsStates

public Map<StreamDefinition,org.springframework.cloud.deployer.spi.app.DeploymentState> streamsStates(List<StreamDefinition> streamDefinitions)

Description copied from interface: StreamDeployer

Get the deployment states for a list of stream definitions

Specified by:

streamsStates in interface StreamDeployer

Returns:

map of stream definition and its corresponding deployment state

deployStream

public org.springframework.cloud.skipper.domain.Release deployStream(StreamDeploymentRequest streamDeploymentRequest)

validateAppVersionIsRegistered

public void validateAppVersionIsRegistered(org.springframework.cloud.deployer.spi.core.AppDeploymentRequest appDeploymentRequest,
                                           String appVersion)

undeployStream

public void undeployStream(String streamName)

getAppStatuses

public org.springframework.data.domain.Page<org.springframework.cloud.deployer.spi.app.AppStatus> getAppStatuses(org.springframework.data.domain.Pageable pageable)
                                                                                                          throws ExecutionException,
                                                                                                                 InterruptedException

Description copied from interface: StreamDeployer

Returns application statuses of all deployed applications

Specified by:

getAppStatuses in interface StreamDeployer

Returns:

pagable list of all app statuses

Throws:

ExecutionException

InterruptedException

getAppStatus

public org.springframework.cloud.deployer.spi.app.AppStatus getAppStatus(String appDeploymentId)

Description copied from interface: StreamDeployer

Gets runtime application status

Specified by:

getAppStatus in interface StreamDeployer

Parameters:

appDeploymentId - the id of the application instance running in the target runtime environment

Returns:

app status

environmentInfo

public org.springframework.cloud.deployer.spi.core.RuntimeEnvironmentInfo environmentInfo()

Specified by:

environmentInfo in interface StreamDeployer

Returns:

the runtime environment info for deploying streams.

getStreamInfo

public StreamDeployment getStreamInfo(String streamName)

Description copied from interface: StreamDeployer

Get stream information (including the deployment properties) for the given stream name.

Specified by:

getStreamInfo in interface StreamDeployer

Parameters:

streamName - the name of the stream

Returns:

stream deployment information

upgradeStream

public 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.

Parameters:

streamName - the name of the stream to upgrade

packageIdentifier - the name of the package in skipper

configYml - the YML formatted configuration values to use when upgrading

rollbackStream

public void rollbackStream(String streamName,
                           int releaseVersion)

Rollback the stream to a specific version

Parameters:

streamName - the name of the stream to rollback

releaseVersion - the version of the stream to rollback to

manifest

public String manifest(String name,
                       int version)

manifest

public String manifest(String name)

history

public Collection<org.springframework.cloud.skipper.domain.Release> history(String releaseName)

platformList

public Collection<org.springframework.cloud.skipper.domain.Deployer> platformList()