Module org.elasticsearch.server

Package org.elasticsearch.repositories

Class RepositoriesService.RegisterRepositoryTask

java.lang.Object

org.elasticsearch.cluster.ClusterStateUpdateTask

org.elasticsearch.cluster.AckedClusterStateUpdateTask

org.elasticsearch.repositories.RepositoriesService.RegisterRepositoryTask

All Implemented Interfaces:

ClusterStateAckListener, ClusterStateTaskListener

Enclosing class:

RepositoriesService

public static class RepositoriesService.RegisterRepositoryTask
extends AckedClusterStateUpdateTask

Task class that extracts the 'execute' part of the functionality for registering repositories.

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	changed
protected boolean	found

Constructor Summary

Constructors

Constructor	Description
RegisterRepositoryTask(RepositoriesService repositoriesService, PutRepositoryRequest request)	Constructor used by ReservedRepositoryAction

Method Summary

Modifier and Type	Method	Description
ClusterState	execute(ClusterState currentState)	Computes the cluster state that results from executing this task on the given state.

Methods inherited from class org.elasticsearch.cluster.AckedClusterStateUpdateTask

ackTimeout, mustAck, newResponse, onAckFailure, onAckTimeout, onAllNodesAcked, onFailure

Methods inherited from class org.elasticsearch.cluster.ClusterStateUpdateTask

clusterStateProcessed, priority, timeout

Methods inherited from class java.lang.Object

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

Field Details

found

protected boolean found

changed

protected boolean changed

Constructor Details

RegisterRepositoryTask

public RegisterRepositoryTask(RepositoriesService repositoriesService,
 PutRepositoryRequest request)

Constructor used by ReservedRepositoryAction

Parameters:

repositoriesService -

request -

Method Details

execute

public ClusterState execute(ClusterState currentState)

Description copied from class: ClusterStateUpdateTask

Computes the cluster state that results from executing this task on the given state. Returns the *same instance* if no change is required, which is an important and valuable optimisation since it short-circuits the whole publication process and saves a bunch of time and effort.

Specified by:

execute in class ClusterStateUpdateTask