org.springframework.cloud.dataflow.server.service.impl

Class DefaultTaskDeleteService

java.lang.Object

org.springframework.cloud.dataflow.server.service.impl.DefaultTaskDeleteService

All Implemented Interfaces:

TaskDeleteService

public class DefaultTaskDeleteService
extends Object
implements TaskDeleteService

Default implementation of the TaskDeleteService interface. Provide service methods for Task deletion.

Author:

Michael Minella, Marius Bogoevici, Glenn Renfro, Mark Fisher, Janne Valkealahti, Gunnar Hillert, Thomas Risberg, Ilayaperumal Gopinathan, Michael Wirth, David Turanski, Daniel Serleg

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.cloud.dataflow.audit.service.AuditRecordService	auditRecordService

Constructor Summary

Constructors

Constructor and Description
DefaultTaskDeleteService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer, LauncherRepository launcherRepository, TaskDefinitionRepository taskDefinitionRepository, TaskDeploymentRepository taskDeploymentRepository, org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService)

Method Summary

Modifier and Type	Method and Description
void	cleanupExecution(long id) Cleanup the resources that resulted from running the task with the given execution id.
void	deleteAll() Destroy all task definitions.
void	deleteTaskDefinition(String name) Destroy the task definition.

Methods inherited from class java.lang.Object

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

Field Detail

auditRecordService

protected final org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService

Constructor Detail

DefaultTaskDeleteService

public DefaultTaskDeleteService(org.springframework.cloud.task.repository.TaskExplorer taskExplorer,
                                LauncherRepository launcherRepository,
                                TaskDefinitionRepository taskDefinitionRepository,
                                TaskDeploymentRepository taskDeploymentRepository,
                                org.springframework.cloud.dataflow.audit.service.AuditRecordService auditRecordService)

Method Detail

cleanupExecution

public void cleanupExecution(long id)

Description copied from interface: TaskDeleteService

Cleanup the resources that resulted from running the task with the given execution id.

Specified by:

cleanupExecution in interface TaskDeleteService

Parameters:

id - the execution id

deleteTaskDefinition

public void deleteTaskDefinition(String name)

Description copied from interface: TaskDeleteService

Destroy the task definition. If it is a Composed Task then the task definitions required for a ComposedTaskRunner task are also destroyed.

Specified by:

deleteTaskDefinition in interface TaskDeleteService

Parameters:

name - The name of the task.

deleteAll

public void deleteAll()

Description copied from interface: TaskDeleteService

Destroy all task definitions. If it is a Composed Task then the task definitions required for a ComposedTaskRunner tasks are also destroyed.

Specified by:

deleteAll in interface TaskDeleteService