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

Class AppDeployerStreamService

java.lang.Object

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

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

All Implemented Interfaces:

StreamService

@Transactional
public class AppDeployerStreamService
extends AbstractStreamService

AppDeployerStreamDeployer specific AbstractStreamService.

Author:

Mark Pollack, Ilayaperumal Gopinathan, Christian Tzolov

Field Summary

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

streamDefinitionRepository

Constructor Summary

Constructors

Constructor and Description
AppDeployerStreamService(StreamDefinitionRepository streamDefinitionRepository, AppDeployerStreamDeployer appDeployerStreamDeployer, 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)
StreamDeployment	info(String streamName) Get stream information including the deployment properties etc.
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.

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

Constructor Detail

AppDeployerStreamService

public AppDeployerStreamService(StreamDefinitionRepository streamDefinitionRepository,
                                AppDeployerStreamDeployer appDeployerStreamDeployer,
                                AppDeploymentRequestCreator appDeploymentRequestCreator,
                                AppRegistryCommon appRegistry)

Method Detail

doCalculateStreamState

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

Specified by:

doCalculateStreamState in class AbstractStreamService

doDeployStream

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

Specified by:

doDeployStream in class AbstractStreamService

undeployStream

public void undeployStream(String streamName)

Description copied from interface: StreamService

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

Parameters:

streamName - the name of the stream to un-deploy

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.

Parameters:

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

Returns:

the map containing the stream definitions and their deployment states.

info

public StreamDeployment info(String streamName)

Description copied from interface: StreamService

Get stream information including the deployment properties etc.

Parameters:

streamName - the name of the stream

Returns:

the stream deployment information