@Component public class StreamCommands extends Object implements org.springframework.shell.core.CommandMarker
Constructor and Description |
---|
StreamCommands() |
Modifier and Type | Method and Description |
---|---|
boolean |
availableWithCreateRole() |
boolean |
availableWithViewRole() |
String |
createStream(String name,
String dsl,
boolean deploy) |
String |
deployStream(String name,
String deploymentProperties,
File propertiesFile) |
String |
deployStreamUsingSkipper(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) |
org.springframework.shell.table.Table |
history(String name,
int max) |
org.springframework.shell.table.Table |
listPlatforms() |
org.springframework.shell.table.Table |
listStreams() |
String |
rollbackStreamUsingSkipper(String name,
int releaseVersion) |
String |
undeployAllStreams(boolean force) |
String |
undeployStream(String name) |
String |
updateStream(String name,
String properties,
File propertiesFile,
String packageVersion,
String repoName) |
@CliAvailabilityIndicator(value="stream list") public boolean availableWithViewRole()
@CliAvailabilityIndicator(value={"stream create","stream deploy","stream skipper deploy","stream skipper update","stream undeploy","stream all undeploy","stream destroy","stream all destroy"}) public boolean availableWithCreateRole()
@CliCommand(value="stream list", help="List created streams") public org.springframework.shell.table.Table listStreams()
@CliCommand(value="stream create", help="Create a new stream definition") public String createStream(@CliOption(mandatory=true,key={"","name"},help="the name to give to the stream") String name, @CliOption(mandatory=true,key="definition",help="a stream definition, using the DSL (e.g. \"http --port=9000 | hdfs\")",optionContext="disable-string-converter completion-stream") String dsl, @CliOption(key="deploy",help="whether to deploy the stream immediately",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean deploy)
@CliCommand(value="stream skipper deploy", help="Deploy a previously created stream using Skipper") public String deployStreamUsingSkipper(@CliOption(key={"","name"},help="the name of the stream to deploy",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="properties",help="the properties for this deployment") String deploymentProperties, @CliOption(key="propertiesFile",help="the properties for this deployment (as a File)") File propertiesFile, @CliOption(key="packageVersion",help="the package version of the package to deploy. Default is 1.0.0when using Skipper",unspecifiedDefaultValue="1.0.0") String packageVersion, @CliOption(key="platformName",help="the name of the target platform to deploy when using Skipper") String platformName, @CliOption(key="repoName",help="the name of the local repository to upload the package when using Skipper") String repoName) throws IOException
IOException
@CliCommand(value="stream deploy", help="Deploy a previously created stream") public String deployStream(@CliOption(key={"","name"},help="the name of the stream to deploy",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="properties",help="the properties for this deployment") String deploymentProperties, @CliOption(key="propertiesFile",help="the properties for this deployment (as a File)") File propertiesFile) throws IOException
IOException
@CliCommand(value="stream skipper manifest", help="Get manifest for the stream deployed using Skipper") public String getManifest(@CliOption(key={"","name"},help="the name of the stream",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="releaseVersion",help="the Skipper release version to get the manifest for",unspecifiedDefaultValue="0") int releaseVersion)
@CliCommand(value="stream skipper history", help="Get history for the stream deployed using Skipper") public org.springframework.shell.table.Table history(@CliOption(key={"","name"},help="the name of the stream",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="max",help="the maximum number of revisions to retrieve",unspecifiedDefaultValue="0") int max)
@CliCommand(value="stream skipper platform-list", help="List Skipper platforms") public org.springframework.shell.table.Table listPlatforms()
@CliCommand(value="stream skipper update", help="Update a previously created stream using Skipper") public String updateStream(@CliOption(key={"","name"},help="the name of the stream to update",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="properties",help="Flattened YAML style properties to update the stream",mandatory=false) String properties, @CliOption(key="propertiesFile",help="the properties for the stream update (as a File)",mandatory=false) File propertiesFile, @CliOption(key="packageVersion",help="the package version of the package to update when using Skipper") String packageVersion, @CliOption(key="repoName",help="the name of the local repository to upload the package when using Skipper") String repoName) throws IOException
IOException
@CliCommand(value="stream skipper rollback", help="Rollback a stream using Skipper") public String rollbackStreamUsingSkipper(@CliOption(key={"","name"},help="the name of the stream to rollback",mandatory=true,optionContext="existing-stream disable-string-converter") String name, @CliOption(key="releaseVersion",help="the Skipper release version to rollback to",unspecifiedDefaultValue="0") int releaseVersion)
@CliCommand(value="stream undeploy", help="Un-deploy a previously deployed stream") public String undeployStream(@CliOption(key={"","name"},help="the name of the stream to un-deploy",mandatory=true,optionContext="existing-stream disable-string-converter") String name)
@CliCommand(value="stream all undeploy", help="Un-deploy all previously deployed stream") public String undeployAllStreams(@CliOption(key="force",help="bypass confirmation prompt",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean force)
@CliCommand(value="stream destroy", help="Destroy an existing stream") public String destroyStream(@CliOption(key={"","name"},help="the name of the stream to destroy",mandatory=true,optionContext="existing-stream disable-string-converter") String name)
@CliCommand(value="stream all destroy", help="Destroy all existing streams") public String destroyAllStreams(@CliOption(key="force",help="bypass confirmation prompt",unspecifiedDefaultValue="false",specifiedDefaultValue="true") boolean force)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.