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

Class TaskCommands

java.lang.Object

org.springframework.cloud.dataflow.shell.command.TaskCommands

@ShellComponent
public class TaskCommands
extends Object

Task commands.

Author:

Glenn Renfro, Michael Minella, Gunnar Hillert, Ilayaperumal Gopinathan, Janne Valkealahti, David Turanski, Mike Baranski, Chris Bono, Corneil du Plessis

Field Summary

Fields

Modifier and Type	Field	Description
protected UserInput	userInput

Constructor Summary

Constructors

Constructor	Description
TaskCommands()

Method Summary

Modifier and Type	Method	Description
Availability	availableWithCreateRole()
Availability	availableWithDeployRole()
Availability	availableWithDestroyRole()
Availability	availableWithUnDeployRole()
Availability	availableWithViewRole()
String	cleanup(Long id, boolean all, boolean includeNonCompleted, String taskName, boolean force)
String	create(String name, String dsl, String description)
Table	currentExecutions()
String	destroy(String name, boolean cleanup)
String	destroyAll(boolean force)
Table	display(long id)
Table	executionListByName(String name)
String	launch(String name, String properties, File propertiesFile, String arguments, String platformName)
Table	list()
Table	listPlatforms()
String	retrieveTaskExecutionLog(Long id, String externalExecutionId, String platform)
String	stop(String ids, String platform)
TablesInfo	validate(String name)

Methods inherited from class java.lang.Object

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

Field Details

userInput

@Autowired
protected UserInput userInput

Constructor Details

TaskCommands

public TaskCommands()

Method Details

availableWithViewRole

public Availability availableWithViewRole()

availableWithCreateRole

public Availability availableWithCreateRole()

availableWithDeployRole

public Availability availableWithDeployRole()

availableWithUnDeployRole

public Availability availableWithUnDeployRole()

availableWithDestroyRole

public Availability availableWithDestroyRole()

list

@ShellMethod(key="task list",
             value="List created tasks")
@ShellMethodAvailability("availableWithViewRole")
public Table list()

listPlatforms

@ShellMethod(key="task platform-list",
             value="List platform accounts for tasks")
@ShellMethodAvailability("availableWithViewRole")
public Table listPlatforms()

validate

@ShellMethod(key="task validate",
             value="Validate apps contained in task definitions")
public TablesInfo validate(@ShellOption(value={"","--name"},help="the task definition name")
 String name)
                    throws OperationNotSupportedException

Throws:

OperationNotSupportedException

create

@ShellMethod(key="task create",
             value="Create a new task definition")
@ShellMethodAvailability("availableWithCreateRole")
public String create(@ShellOption(value={"","--name"},help="the name to give to the task")
 String name,
 @ShellOption(value="--definition",help="a task definition, using the DSL (e.g. \"timestamp --format=YYYY\")")
 String dsl,
 @ShellOption(help="a sort description about the task",defaultValue="")
 String description)

launch

@ShellMethod(key="task launch",
             value="Launch a previously created task")
@ShellMethodAvailability("availableWithDeployRole")
public String launch(@ShellOption(value={"","--name"},help="the name of the task to launch")
 String name,
 @ShellOption(help="the properties for this launch",defaultValue="__NULL__")
 String properties,
 @ShellOption(value="--propertiesFile",help="the properties for this launch (as a File)",defaultValue="__NULL__")
 File propertiesFile,
 @ShellOption(help="the commandline arguments for this launch",defaultValue="__NULL__")
 String arguments,
 @ShellOption(value="--platformName",help="the platform name to use for this launch",defaultValue="__NULL__")
 String platformName)
              throws IOException

Throws:

IOException

stop

@ShellMethod(key="task execution stop",
             value="Stop executing tasks")
@ShellMethodAvailability("availableWithUnDeployRole")
public String stop(@ShellOption(value={"","--ids"},help="the task execution id")
 String ids,
 @ShellOption(value="--platformName",help="the name of the platform where the task is executing",defaultValue="__NULL__")
 String platform)

retrieveTaskExecutionLog

@ShellMethod(key="task execution log",
             value="Retrieve task execution log")
public String retrieveTaskExecutionLog(@ShellOption(value={"","--id"},help="the task execution id",defaultValue="__NULL__")
 Long id,
 @ShellOption(value={"","--externalExecutionId"},help="the task external execution id",defaultValue="__NULL__")
 String externalExecutionId,
 @ShellOption(help="the platform of the task execution",defaultValue="__NULL__")
 String platform)

destroy

@ShellMethod(key="task destroy",
             value="Destroy an existing task")
@ShellMethodAvailability("availableWithDestroyRole")
public String destroy(@ShellOption(value={"","--name"},help="the name of the task to destroy",valueProvider=TaskNameValueProvider.class)
 String name,
 @ShellOption(help="the boolean flag to set if task executions and related resources should NOT also be cleaned up",defaultValue="false")
 boolean cleanup)

destroyAll

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

executionListByName

@ShellMethod(key="task execution list",
             value="List created task executions filtered by taskName")
@ShellMethodAvailability("availableWithViewRole")
public Table executionListByName(@ShellOption(value={"","--name"},help="the task name to be used as a filter",valueProvider=TaskNameValueProvider.class,defaultValue="__NULL__")
 String name)

display

@ShellMethod(key="task execution status",
             value="Display the details of a specific task execution")
@ShellMethodAvailability("availableWithViewRole")
public Table display(@ShellOption(value={"","--id"},help="the task execution id")
 long id)

currentExecutions

@ShellMethod(key="task execution current",
             value="Display count of currently executin tasks and related information")
@ShellMethodAvailability("availableWithViewRole")
public Table currentExecutions()

cleanup

@ShellMethod(key="task execution cleanup",
             value="Clean up any platform specific resources linked to a task execution")
@ShellMethodAvailability("availableWithDestroyRole")
public String cleanup(@ShellOption(value={"","--id"},help="the task execution id",defaultValue="__NULL__")
 Long id,
 @ShellOption(help="all task execution IDs",defaultValue="false")
 boolean all,
 @ShellOption(help="include non-completed task executions",defaultValue="false")
 boolean includeNonCompleted,
 @ShellOption(value="--task-name",help="the name of the task to cleanup",defaultValue="__NULL__")
 String taskName,
 @ShellOption(help="bypass confirmation prompt",defaultValue="false")
 boolean force)