org.springframework.cloud.dataflow.server.service.impl

Class DefaultSkipperStreamService

java.lang.Object

org.springframework.cloud.dataflow.server.service.impl.AbstractStreamService

org.springframework.cloud.dataflow.server.service.impl.DefaultSkipperStreamService

All Implemented Interfaces:

SkipperStreamService, StreamService

@Transactional
public class DefaultSkipperStreamService
extends AbstractStreamService
implements SkipperStreamService

An implementation of SkipperStreamService.

Author:

Mark Pollack, Ilayaperumal Gopinathan, Christian Tzolov

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_SKIPPER_PACKAGE_VERSION

Fields inherited from class org.springframework.cloud.dataflow.server.service.impl.AbstractStreamService

streamDefinitionRepository

Constructor Summary

Constructors

Constructor and Description
DefaultSkipperStreamService(StreamDefinitionRepository streamDefinitionRepository, SkipperStreamDeployer skipperStreamDeployer, AppDeploymentRequestCreator appDeploymentRequestCreator, AppRegistryCommon appRegistry)

Method Summary

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)
void	updateStream(String streamName, UpdateStreamRequest updateStreamRequest) Update the stream using the UpdateStreamRequest.

Methods inherited from class org.springframework.cloud.dataflow.server.service.impl.AbstractStreamService

createStream, deleteAll, deleteStream, deployStream, findDefinitionByNameLike, findOne, findRelatedStreams

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.dataflow.server.service.StreamService

createStream, deleteAll, deleteStream, deployStream, findDefinitionByNameLike, findOne, findRelatedStreams

Field Detail

DEFAULT_SKIPPER_PACKAGE_VERSION

public static final String DEFAULT_SKIPPER_PACKAGE_VERSION

See Also:

Constant Field Values

Constructor Detail

DefaultSkipperStreamService

public DefaultSkipperStreamService(StreamDefinitionRepository streamDefinitionRepository,
                                   SkipperStreamDeployer skipperStreamDeployer,
                                   AppDeploymentRequestCreator appDeploymentRequestCreator,
                                   AppRegistryCommon appRegistry)

Method Detail

doDeployStream

public void doDeployStream(StreamDefinition streamDefinition,
                           Map<String,String> deploymentProperties)

Deploy a stream as defined by its stream name and optional deployment properties.

Specified by:

doDeployStream in class AbstractStreamService

Parameters:

streamDefinition - the stream definition to deploy

deploymentProperties - the deployment properties for the stream

doCalculateStreamState

public org.springframework.cloud.deployer.spi.app.DeploymentState doCalculateStreamState(String name)

Specified by:

doCalculateStreamState in class AbstractStreamService

undeployStream

public void undeployStream(String streamName)

Description copied from interface: StreamService

Un-deploys the stream identified by the given stream name.

Specified by:

undeployStream in interface StreamService

Parameters:

streamName - the name of the stream to un-deploy

updateStream

public void updateStream(String streamName,
                         UpdateStreamRequest updateStreamRequest)

Description copied from interface: SkipperStreamService

Update the stream using the UpdateStreamRequest.

Specified by:

updateStream in interface SkipperStreamService

Parameters:

streamName - the name of the stream to update

updateStreamRequest - the UpdateStreamRequest to use during the update

updateStream

public void updateStream(String streamName,
                         String releaseName,
                         org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier,
                         Map<String,String> updateProperties)

rollbackStream

public void rollbackStream(String streamName,
                           int releaseVersion)

Description copied from interface: SkipperStreamService

Rollback the stream to the previous or a specific version of the stream.

Specified by:

rollbackStream in interface SkipperStreamService

Parameters:

streamName - the name of the stream to rollback

releaseVersion - the version to rollback to (if not specified, rollback to the previous deleted/deployed release version of the stream.

state

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

Description copied from interface: StreamService

Retrieve the deployment state for list of stream definitions.

Specified by:

state in interface StreamService

Parameters:

streamDefinitions - the list of Stream definitions to calculate the deployment states.

Returns:

the map containing the stream definitions and their deployment states.

manifest

public String manifest(String name,
                       int version)

Description copied from interface: SkipperStreamService

Return a manifest info of a release version. For packages with dependencies, the manifest includes the contents of those dependencies.

Specified by:

manifest in interface SkipperStreamService

Parameters:

name - the release name

version - the release version

Returns:

the manifest info of a release

history

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

Description copied from interface: SkipperStreamService

Get stream's deployment history

Specified by:

history in interface SkipperStreamService

Parameters:

releaseName - Stream release name

Returns:

List or Releases for this release name

platformList

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

Specified by:

platformList in interface SkipperStreamService

Returns:

list of supported deployment platforms

info

public StreamDeployment info(String streamName)

Description copied from interface: StreamService

Get stream information including the deployment properties etc.

Specified by:

info in interface StreamService

Parameters:

streamName - the name of the stream

Returns:

the stream deployment information