org.springframework.cloud.dataflow.rest.client

Class StreamTemplate

java.lang.Object

org.springframework.cloud.dataflow.rest.client.StreamTemplate

All Implemented Interfaces:

StreamOperations

public class StreamTemplate
extends Object
implements StreamOperations

Implementation for StreamOperations.

Author:

Ilayaperumal Gopinathan, Mark Fisher, Eric Bottard

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFINITIONS_REL

Method Summary

Modifier and Type	Method and Description
StreamDefinitionResource	createStream(String name, String definition, boolean deploy) Create a new stream, optionally deploying it.
void	deploy(String name, Map<String,String> properties) Deploy an already created stream.
void	destroy(String name) Destroy an existing stream.
void	destroyAll() Destroy all streams known to the system.
String	getManifest(String streamName, int version) Get manifest for the given stream deployed via Skipper.
StreamDefinitionResource	getStreamDefinition(String streamName) Queries the server for the stream definition.
Collection<org.springframework.cloud.skipper.domain.Release>	history(String streamName) Get the history of releases for the given stream deployed via Skipper.
StreamDeploymentResource	info(String name)
StreamDefinitionResource.Page	list()
Collection<org.springframework.cloud.skipper.domain.Deployer>	listPlatforms()
void	rollbackStream(String streamName, int version) Rollback the stream to the previous or a specific release version.
void	undeploy(String name) Undeploy a deployed stream, retaining its definition.
void	undeployAll() Undeploy all currently deployed streams.
void	updateStream(String streamName, String releaseName, org.springframework.cloud.skipper.domain.PackageIdentifier packageIdentifier, Map<String,String> updateProperties) Update the stream given its corresponding releaseName in Skipper using the specified package and updated yaml config.

Methods inherited from class java.lang.Object

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

Field Detail

DEFINITIONS_REL

public static final String DEFINITIONS_REL

See Also:

Constant Field Values

Method Detail

list

public StreamDefinitionResource.Page list()

Specified by:

list in interface StreamOperations

Returns:

the list streams known to the system.

info

public StreamDeploymentResource info(String name)

Specified by:

info in interface StreamOperations

Parameters:

name - the name of the stream

Returns:

retrieve the stream info.

createStream

public StreamDefinitionResource createStream(String name,
                                             String definition,
                                             boolean deploy)

Description copied from interface: StreamOperations

Create a new stream, optionally deploying it.

Specified by:

createStream in interface StreamOperations

Parameters:

name - the name of the stream

definition - the stream definition DSL

deploy - whether to deploy the stream after creating its definition

Returns:

the new stream definition

deploy

public void deploy(String name,
                   Map<String,String> properties)

Description copied from interface: StreamOperations

Deploy an already created stream.

Specified by:

deploy in interface StreamOperations

Parameters:

name - the name of the stream

properties - the deployment properties

undeploy

public void undeploy(String name)

Description copied from interface: StreamOperations

Undeploy a deployed stream, retaining its definition.

Specified by:

undeploy in interface StreamOperations

Parameters:

name - the name of the stream

undeployAll

public void undeployAll()

Description copied from interface: StreamOperations

Undeploy all currently deployed streams.

Specified by:

undeployAll in interface StreamOperations

destroy

public void destroy(String name)

Description copied from interface: StreamOperations

Destroy an existing stream.

Specified by:

destroy in interface StreamOperations

Parameters:

name - the name of the stream

destroyAll

public void destroyAll()

Description copied from interface: StreamOperations

Destroy all streams known to the system.

Specified by:

destroyAll in interface StreamOperations

updateStream

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

Description copied from interface: StreamOperations

Update the stream given its corresponding releaseName in Skipper using the specified package and updated yaml config.

Specified by:

updateStream in interface StreamOperations

Parameters:

streamName - the name of the stream to update

releaseName - the corresponding release name of the stream in skipper

packageIdentifier - the package that corresponds to this stream

updateProperties - a map of properties to use for updating the stream

rollbackStream

public void rollbackStream(String streamName,
                           int version)

Description copied from interface: StreamOperations

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

Specified by:

rollbackStream in interface StreamOperations

Parameters:

streamName - the name of the stream to rollback

version - the version to rollback to. If the version is 0, then rollback to the previous release. The version can not be less than zero.

getManifest

public String getManifest(String streamName,
                          int version)

Description copied from interface: StreamOperations

Get manifest for the given stream deployed via Skipper. Optionally, the version can be used to retrieve the version for a specific version of the stream.

Specified by:

getManifest in interface StreamOperations

Parameters:

streamName - the stream(release) name

version - the version of the release

Returns:

the manifest for the given stream and version

history

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

Description copied from interface: StreamOperations

Get the history of releases for the given stream deployed via Skipper.

Specified by:

history in interface StreamOperations

Parameters:

streamName - the stream(release) name

Returns:

the history of releases for the stream

listPlatforms

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

Specified by:

listPlatforms in interface StreamOperations

Returns:

the list of all Skipper platforms

getStreamDefinition

public StreamDefinitionResource getStreamDefinition(String streamName)

Description copied from interface: StreamOperations

Queries the server for the stream definition.

Specified by:

getStreamDefinition in interface StreamOperations

Parameters:

streamName - the name of the stream to get status

Returns:

The current stream definition with updated status