Package org.springframework.cloud.dataflow.shell.command

Class StreamCommands

java.lang.Object

org.springframework.cloud.dataflow.shell.command.StreamCommands

@ShellComponent
public class StreamCommands
extends Object

Stream commands.

Author:

Ilayaperumal Gopinathan, Mark Fisher, Gunnar Hillert, Glenn Renfro, Janne Valkealahti, Christian Tzolov, Chris Bono

Constructor Summary

Constructors

Constructor	Description
StreamCommands(DataFlowShell dataFlowShell, ConsoleUserInput userInput)

Method Summary

Modifier and Type	Method	Description
Availability	availableWithCreateRole()
Availability	availableWithDeployRole()
Availability	availableWithDestroyRole()
Availability	availableWithModifyRole()
Availability	availableWithViewRole()
String	createStream(String name, String dsl, String description, boolean deploy)
String	deployStream(String name, String deploymentProperties, File propertiesFile, String packageVersion, String platformName, String repoName)
String	destroyAllStreams(boolean force)
String	destroyStream(String name)
String	getManifest(String name, int releaseVersion)
Table	history(String name)
Table	listPlatforms()
Table	listStreams()
String	rollbackStreamUsingSkipper(String name, int releaseVersion)
String	scaleStream(String name, String applicationName, Integer count, String scaleProperties)
TablesInfo	streamInfo(String name)
protected StreamOperations	streamOperations()
String	undeployAllStreams(boolean force)
String	undeployStream(String name)
String	updateStream(String name, String properties, File propertiesFile, String packageVersion, String repoName, boolean force, String appNames)
TablesInfo	validateStream(String name)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamCommands

public StreamCommands(DataFlowShell dataFlowShell,
 ConsoleUserInput userInput)

Method Details

availableWithCreateRole

public Availability availableWithCreateRole()

availableWithDeployRole

public Availability availableWithDeployRole()

availableWithDestroyRole

public Availability availableWithDestroyRole()

availableWithModifyRole

public Availability availableWithModifyRole()

availableWithViewRole

public Availability availableWithViewRole()

deployStream

@ShellMethod(key="stream deploy",
             value="Deploy a previously created stream using Skipper")
@ShellMethodAvailability("availableWithDeployRole")
public String deployStream(@ShellOption(value={"","--name"},help="the name of the stream to deploy",valueProvider=StreamNameValueProvider.class)
 String name,
 @ShellOption(value="--properties",help="the properties for this deployment",defaultValue="__NULL__")
 String deploymentProperties,
 @ShellOption(value="--propertiesFile",help="the properties for this deployment (as a File)",defaultValue="__NULL__")
 File propertiesFile,
 @ShellOption(value="--packageVersion",help="the package version of the package to deploy.  Default is 1.0.0",defaultValue="1.0.0")
 String packageVersion,
 @ShellOption(value="--platformName",help="the name of the target platform to deploy to",defaultValue="__NULL__")
 String platformName,
 @ShellOption(value="--repoName",help="the name of the local repository to upload the package to",defaultValue="__NULL__")
 String repoName)
                    throws IOException

Throws:

IOException

getManifest

@ShellMethod(key="stream manifest",
             value="Get manifest for the stream deployed using Skipper")
@ShellMethodAvailability("availableWithViewRole")
public String getManifest(@ShellOption(value={"","--name"},help="the name of the stream",valueProvider=StreamNameValueProvider.class)
 String name,
 @ShellOption(value="--releaseVersion",help="the Skipper release version to get the manifest for",defaultValue="0")
 int releaseVersion)

history

@ShellMethod(key="stream history",
             value="Get history for the stream deployed using Skipper")
@ShellMethodAvailability("availableWithViewRole")
public Table history(@ShellOption(value={"","--name"},help="the name of the stream",valueProvider=StreamNameValueProvider.class)
 String name)

listPlatforms

@ShellMethod(key="stream platform-list",
             value="List Skipper platforms")
@ShellMethodAvailability("availableWithViewRole")
public Table listPlatforms()

updateStream

@ShellMethod(key="stream update",
             value="Update a previously created stream using Skipper")
@ShellMethodAvailability("availableWithModifyRole")
public String updateStream(@ShellOption(value={"","--name"},help="the name of the stream",valueProvider=StreamNameValueProvider.class)
 String name,
 @ShellOption(value="--properties",help="Flattened YAML style properties to update the stream",defaultValue="__NULL__")
 String properties,
 @ShellOption(value="--propertiesFile",help="the properties for the stream update (as a File)",defaultValue="__NULL__")
 File propertiesFile,
 @ShellOption(value="--packageVersion",help="the package version of the package to update when using Skipper",defaultValue="__NULL__")
 String packageVersion,
 @ShellOption(value="--repoName",help="the name of the local repository to upload the package when using Skipper",defaultValue="__NULL__")
 String repoName,
 @ShellOption(help="force the update",defaultValue="false")
 boolean force,
 @ShellOption(value="--appNames",help="the application names to force update",defaultValue="__NULL__")
 String appNames)
                    throws IOException

Throws:

IOException

scaleStream

@ShellMethod(key="stream scale app instances",
             value="Scale app instances in a stream")
@ShellMethodAvailability("availableWithModifyRole")
public String scaleStream(@ShellOption(value={"","--name"},help="the name of the stream to scale",valueProvider=StreamNameValueProvider.class)
 String name,
 @ShellOption(value="--applicationName",help="the name/label of the application to scale")
 String applicationName,
 @ShellOption(help="desired number of application instances")
 Integer count,
 @ShellOption(value="--properties",help="the properties for this scale",defaultValue="__NULL__")
 String scaleProperties)
                   throws IOException

Throws:

IOException

rollbackStreamUsingSkipper

@ShellMethod(key="stream rollback",
             value="Rollback a stream using Skipper")
@ShellMethodAvailability("availableWithModifyRole")
public String rollbackStreamUsingSkipper(@ShellOption(value={"","--name"},help="the name of the stream to rollback",valueProvider=StreamNameValueProvider.class)
 String name,
 @ShellOption(value="--releaseVersion",help="the Skipper release version to rollback to",defaultValue="0")
 int releaseVersion)

createStream

@ShellMethod(key="stream create",
             value="Create a new stream definition")
@ShellMethodAvailability("availableWithCreateRole")
public String createStream(@ShellOption(value={"","--name"},help="the name to give to the stream")
 String name,
 @ShellOption(value="--definition",help="a stream definition, using the DSL (e.g. \"http --port=9000 | hdfs\")")
 String dsl,
 @ShellOption(help="a short description about the stream",defaultValue="")
 String description,
 @ShellOption(help="whether to deploy the stream immediately",defaultValue="false")
 boolean deploy)

listStreams

@ShellMethod(key="stream list",
             value="List created streams")
@ShellMethodAvailability("availableWithViewRole")
public Table listStreams()

streamInfo

@ShellMethod(key="stream info",
             value="Show information about a specific stream")
@ShellMethodAvailability("availableWithViewRole")
public TablesInfo streamInfo(@ShellOption(value={"","--name"},help="the name of the stream to show",valueProvider=StreamNameValueProvider.class)
 String name)

undeployStream

@ShellMethod(key="stream undeploy",
             value="Un-deploy a previously deployed stream")
@ShellMethodAvailability("availableWithDeployRole")
public String undeployStream(@ShellOption(value={"","--name"},help="the name of the stream to un-deploy",valueProvider=StreamNameValueProvider.class)
 String name)

undeployAllStreams

@ShellMethod(key="stream all undeploy",
             value="Un-deploy all previously deployed stream")
@ShellMethodAvailability("availableWithDeployRole")
public String undeployAllStreams(@ShellOption(help="bypass confirmation prompt",defaultValue="false")
 boolean force)

destroyStream

@ShellMethod(key="stream destroy",
             value="Destroy an existing stream")
@ShellMethodAvailability("availableWithDestroyRole")
public String destroyStream(@ShellOption(value={"","--name"},help="the name of the stream to destroy",valueProvider=StreamNameValueProvider.class)
 String name)

destroyAllStreams

@ShellMethod(key="stream all destroy",
             value="Destroy all existing streams")
@ShellMethodAvailability("availableWithDestroyRole")
public String destroyAllStreams(@ShellOption(help="bypass confirmation prompt",defaultValue="false")
 boolean force)

validateStream

@ShellMethod(key="stream validate",
             value="Verify that apps contained in the stream are valid.")
@ShellMethodAvailability("availableWithViewRole")
public TablesInfo validateStream(@ShellOption(value={"","--name"},help="the name of the stream to validate",valueProvider=StreamNameValueProvider.class)
 String name)
                          throws OperationNotSupportedException

Throws:

OperationNotSupportedException

streamOperations

protected StreamOperations streamOperations()