org.springframework.cloud.dataflow.server.stream

Class AppDeployerStreamDeployer

java.lang.Object

org.springframework.cloud.dataflow.server.stream.AppDeployerStreamDeployer

All Implemented Interfaces:

StreamDeployer

public class AppDeployerStreamDeployer
extends Object
implements StreamDeployer

Uses an AppDeployer instance to deploy the stream.

Author:

Mark Pollack, Ilayaperumal Gopinathan, Christian Tzolov

Constructor Summary

Constructors

Constructor and Description
AppDeployerStreamDeployer(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer, DeploymentIdRepository deploymentIdRepository, StreamDefinitionRepository streamDefinitionRepository, StreamDeploymentRepository streamDeploymentRepository, ForkJoinPool forkJoinPool)

Method Summary

Modifier and Type	Method and Description
void	deployStream(StreamDeploymentRequest streamDeploymentRequest)
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.
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

AppDeployerStreamDeployer

public AppDeployerStreamDeployer(org.springframework.cloud.deployer.spi.app.AppDeployer appDeployer,
                                 DeploymentIdRepository deploymentIdRepository,
                                 StreamDefinitionRepository streamDefinitionRepository,
                                 StreamDeploymentRepository streamDeploymentRepository,
                                 ForkJoinPool forkJoinPool)

Method Detail

deployStream

public void deployStream(StreamDeploymentRequest streamDeploymentRequest)

undeployStream

public void undeployStream(String streamName)

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

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