Package org.springframework.cloud.dataflow.server.controller

Class TaskDefinitionController

java.lang.Object

org.springframework.cloud.dataflow.server.controller.TaskDefinitionController

@RestController
@RequestMapping("/tasks/definitions")
@ExposesResourceFor(TaskDefinitionResource.class)
public class TaskDefinitionController
extends Object

Controller for operations on TaskDefinition. This includes CRUD operations.

Author:

Michael Minella, Marius Bogoevici, Glenn Renfro, Mark Fisher, Gunnar Hillert, Daniel Serleg, Ilayaperumal Gopinathan, Chris Bono

Constructor Summary

Constructors

Constructor	Description
TaskDefinitionController(DataflowTaskExplorer taskExplorer, TaskDefinitionRepository repository, TaskSaveService taskSaveService, TaskDeleteService taskDeleteService, TaskDefinitionAssemblerProvider<? extends TaskDefinitionResource> taskDefinitionAssemblerProvider)	Creates a TaskDefinitionController that delegates CRUD operations to the provided TaskDefinitionRepository task status checks to the provided TaskLauncher

Method Summary

Modifier and Type	Method	Description
void	destroyAll()	Delete all task from the repository.
void	destroyTask(String name, Boolean cleanup)	Delete the task from the repository so that it can no longer be executed.
TaskDefinitionResource	display(String name, boolean manifest)	Return a given task definition resource.
org.springframework.hateoas.PagedModel<? extends TaskDefinitionResource>	list(org.springframework.data.domain.Pageable pageable, String taskName, String description, boolean manifest, String dslText, org.springframework.data.web.PagedResourcesAssembler<TaskExecutionAwareTaskDefinition> assembler)	Return a page-able list of TaskDefinitionResource defined tasks.
TaskDefinitionResource	save(String name, String dsl, String description)	Register a task definition for future execution.

Methods inherited from class java.lang.Object

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

Constructor Details

TaskDefinitionController

public TaskDefinitionController(DataflowTaskExplorer taskExplorer,
 TaskDefinitionRepository repository,
 TaskSaveService taskSaveService,
 TaskDeleteService taskDeleteService,
 TaskDefinitionAssemblerProvider<? extends TaskDefinitionResource> taskDefinitionAssemblerProvider)

Creates a TaskDefinitionController that delegates

• CRUD operations to the provided TaskDefinitionRepository
• task status checks to the provided TaskLauncher

Parameters:

taskExplorer - used to look up TaskExecutions.

repository - the repository this controller will use for task CRUD operations.

taskSaveService - handles Task saving related operations.

taskDeleteService - handles Task deletion related operations.

taskDefinitionAssemblerProvider - the task definition assembler provider to use.

Method Details

save

@PostMapping("")
public TaskDefinitionResource save(@RequestParam
 String name,
 @RequestParam("definition")
 String dsl,
 @RequestParam(defaultValue="")
 String description)

Register a task definition for future execution.

Parameters:

name - name the name of the task

dsl - DSL definition for the task

description - description of the task definition

Returns:

the task definition

destroyTask

@DeleteMapping("/{name}")
@ResponseStatus(OK)
public void destroyTask(@PathVariable
 String name,
 @RequestParam(required=false)
 Boolean cleanup)

Delete the task from the repository so that it can no longer be executed.

Parameters:

name - name of the task to be deleted

cleanup - optional cleanup indicator.

destroyAll

@DeleteMapping("")
@ResponseStatus(OK)
public void destroyAll()

Delete all task from the repository.

list

@GetMapping("")
@ResponseStatus(OK)
public org.springframework.hateoas.PagedModel<? extends TaskDefinitionResource> list(org.springframework.data.domain.Pageable pageable,
 @RequestParam(required=false)
 String taskName,
 @RequestParam(required=false)
 String description,
 @RequestParam(required=false)
 boolean manifest,
 @RequestParam(required=false)
 String dslText,
 org.springframework.data.web.PagedResourcesAssembler<TaskExecutionAwareTaskDefinition> assembler)

Return a page-able list of TaskDefinitionResource defined tasks.

Parameters:

pageable - page-able collection of TaskDefinitionResource

taskName - optional findByTaskNameContains parameter

dslText - optional findByDslText parameter

description - optional findByDescription parameter

manifest - optional manifest flag to indicate whether the latest task execution requires task manifest update

assembler - assembler for the TaskDefinition

Returns:

a list of task definitions

display

@GetMapping("/{name}")
@ResponseStatus(OK)
public TaskDefinitionResource display(@PathVariable
 String name,
 @RequestParam(required=false)
 boolean manifest)

Return a given task definition resource.

Parameters:

name - the name of an existing task definition (required)

manifest - indicator to include manifest in response.

Returns:

the task definition