Package org.elasticsearch.persistent

Class PersistentTasksService

java.lang.Object

org.elasticsearch.persistent.PersistentTasksService

public class PersistentTasksService
extends Object

This service is used by persistent tasks and allocated persistent tasks to communicate changes to the master node so that the master can update the cluster state and can track of the states of the persistent tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	PersistentTasksService.WaitForPersistentTaskListener<P extends PersistentTaskParams>

Field Summary

Fields

Modifier and Type	Field	Description
static String	PERSISTENT_TASK_ORIGIN

Constructor Summary

Constructors

Constructor	Description
PersistentTasksService(ClusterService clusterService, ThreadPool threadPool, Client client)

Method Summary

Modifier and Type	Method	Description
void	sendCompletionRequest(String taskId, long taskAllocationId, Exception taskFailure, ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)	Notifies the master node about the completion of a persistent task.
void	sendRemoveRequest(String taskId, ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)	Notifies the master node to remove a persistent task from the cluster state
<Params extends PersistentTaskParams> void	sendStartRequest(String taskId, String taskName, Params taskParams, ActionListener<PersistentTasksCustomMetadata.PersistentTask<Params>> listener)	Notifies the master node to create new persistent task and to assign it to a node.
void	waitForPersistentTaskCondition(String taskId, Predicate<PersistentTasksCustomMetadata.PersistentTask<?>> predicate, org.elasticsearch.core.TimeValue timeout, PersistentTasksService.WaitForPersistentTaskListener<?> listener)	Waits for a given persistent task to comply with a given predicate, then call back the listener accordingly.
void	waitForPersistentTasksCondition(Predicate<PersistentTasksCustomMetadata> predicate, org.elasticsearch.core.TimeValue timeout, ActionListener<Boolean> listener)	Waits for persistent tasks to comply with a given predicate, then call back the listener accordingly.

Methods inherited from class java.lang.Object

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

Field Details

PERSISTENT_TASK_ORIGIN

public static final String PERSISTENT_TASK_ORIGIN

See Also:

Constant Field Values

Constructor Details

PersistentTasksService

public PersistentTasksService(ClusterService clusterService,
 ThreadPool threadPool,
 Client client)

Method Details

sendStartRequest

public <Params extends PersistentTaskParams> void sendStartRequest(String taskId,
 String taskName,
 Params taskParams,
 ActionListener<PersistentTasksCustomMetadata.PersistentTask<Params>> listener)

Notifies the master node to create new persistent task and to assign it to a node.

sendCompletionRequest

public void sendCompletionRequest(String taskId,
 long taskAllocationId,
 @Nullable
 Exception taskFailure,
 ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)

Notifies the master node about the completion of a persistent task.

When failure is null, the persistent task is considered as successfully completed.

sendRemoveRequest

public void sendRemoveRequest(String taskId,
 ActionListener<PersistentTasksCustomMetadata.PersistentTask<?>> listener)

Notifies the master node to remove a persistent task from the cluster state

waitForPersistentTaskCondition

public void waitForPersistentTaskCondition(String taskId,
 Predicate<PersistentTasksCustomMetadata.PersistentTask<?>> predicate,
 @Nullable
 org.elasticsearch.core.TimeValue timeout,
 PersistentTasksService.WaitForPersistentTaskListener<?> listener)

Waits for a given persistent task to comply with a given predicate, then call back the listener accordingly.

Parameters:

taskId - the persistent task id

predicate - the persistent task predicate to evaluate

timeout - a timeout for waiting

listener - the callback listener

waitForPersistentTasksCondition

public void waitForPersistentTasksCondition(Predicate<PersistentTasksCustomMetadata> predicate,
 @Nullable
 org.elasticsearch.core.TimeValue timeout,
 ActionListener<Boolean> listener)

Waits for persistent tasks to comply with a given predicate, then call back the listener accordingly.

Parameters:

predicate - the predicate to evaluate

timeout - a timeout for waiting

listener - the callback listener