Package org.elasticsearch.client

Interface ClusterAdminClient

All Superinterfaces:

ElasticsearchClient

public interface ClusterAdminClient
extends ElasticsearchClient

Administrative actions/operations against indices.

See Also:

AdminClient.cluster()

Method Summary

Modifier and Type	Method	Description
ActionFuture<ClusterAllocationExplainResponse>	allocationExplain(ClusterAllocationExplainRequest request)	Explain the allocation of a shard
void	allocationExplain(ClusterAllocationExplainRequest request, ActionListener<ClusterAllocationExplainResponse> listener)	Explain the allocation of a shard
ActionFuture<CancelTasksResponse>	cancelTasks(CancelTasksRequest request)	Cancel tasks
void	cancelTasks(CancelTasksRequest request, ActionListener<CancelTasksResponse> listener)	Cancel active tasks
ActionFuture<CleanupRepositoryResponse>	cleanupRepository(CleanupRepositoryRequest repository)	Cleans up repository.
void	cleanupRepository(CleanupRepositoryRequest repository, ActionListener<CleanupRepositoryResponse> listener)	Cleans up repository.
ActionFuture<AcknowledgedResponse>	cloneSnapshot(CloneSnapshotRequest request)	Clones a snapshot.
void	cloneSnapshot(CloneSnapshotRequest request, ActionListener<AcknowledgedResponse> listener)	Clones a snapshot.
ActionFuture<ClusterStatsResponse>	clusterStats(ClusterStatsRequest request)	Cluster wide aggregated stats.
void	clusterStats(ClusterStatsRequest request, ActionListener<ClusterStatsResponse> listener)	Cluster wide aggregated stats
ActionFuture<CreateSnapshotResponse>	createSnapshot(CreateSnapshotRequest request)	Creates a new snapshot.
void	createSnapshot(CreateSnapshotRequest request, ActionListener<CreateSnapshotResponse> listener)	Creates a new snapshot.
ActionFuture<AcknowledgedResponse>	deleteDanglingIndex(DeleteDanglingIndexRequest request)	Delete specified dangling indices.
void	deleteDanglingIndex(DeleteDanglingIndexRequest request, ActionListener<AcknowledgedResponse> listener)	Delete specified dangling indices.
ActionFuture<AcknowledgedResponse>	deletePipeline(DeletePipelineRequest request)	Deletes a stored ingest pipeline
void	deletePipeline(DeletePipelineRequest request, ActionListener<AcknowledgedResponse> listener)	Deletes a stored ingest pipeline
ActionFuture<AcknowledgedResponse>	deleteRepository(DeleteRepositoryRequest request)	Unregisters a repository.
void	deleteRepository(DeleteRepositoryRequest request, ActionListener<AcknowledgedResponse> listener)	Unregisters a repository.
ActionFuture<AcknowledgedResponse>	deleteSnapshot(DeleteSnapshotRequest request)	Delete snapshot.
void	deleteSnapshot(DeleteSnapshotRequest request, ActionListener<AcknowledgedResponse> listener)	Delete snapshot.
ActionFuture<AcknowledgedResponse>	deleteStoredScript(DeleteStoredScriptRequest request)	Delete a script from the cluster state
void	deleteStoredScript(DeleteStoredScriptRequest request, ActionListener<AcknowledgedResponse> listener)	Delete a script from the cluster state
ActionFuture<GetPipelineResponse>	getPipeline(GetPipelineRequest request)	Returns a stored ingest pipeline
void	getPipeline(GetPipelineRequest request, ActionListener<GetPipelineResponse> listener)	Returns a stored ingest pipeline
ActionFuture<GetRepositoriesResponse>	getRepositories(GetRepositoriesRequest request)	Gets repositories.
void	getRepositories(GetRepositoriesRequest request, ActionListener<GetRepositoriesResponse> listener)	Gets repositories.
ActionFuture<GetSnapshotsResponse>	getSnapshots(GetSnapshotsRequest request)	Get snapshots.
void	getSnapshots(GetSnapshotsRequest request, ActionListener<GetSnapshotsResponse> listener)	Get snapshots.
ActionFuture<GetStoredScriptResponse>	getStoredScript(GetStoredScriptRequest request)	Get a script from the cluster state
void	getStoredScript(GetStoredScriptRequest request, ActionListener<GetStoredScriptResponse> listener)	Get a script from the cluster state
ActionFuture<GetTaskResponse>	getTask(GetTaskRequest request)	Get a task.
void	getTask(GetTaskRequest request, ActionListener<GetTaskResponse> listener)	Get a task.
ActionFuture<ClusterHealthResponse>	health(ClusterHealthRequest request)	The health of the cluster.
void	health(ClusterHealthRequest request, ActionListener<ClusterHealthResponse> listener)	The health of the cluster.
ActionFuture<AcknowledgedResponse>	importDanglingIndex(ImportDanglingIndexRequest request)	Restore specified dangling indices.
void	importDanglingIndex(ImportDanglingIndexRequest request, ActionListener<AcknowledgedResponse> listener)	Restore specified dangling indices.
ActionFuture<ListDanglingIndicesResponse>	listDanglingIndices(ListDanglingIndicesRequest request)	List dangling indices on all nodes.
void	listDanglingIndices(ListDanglingIndicesRequest request, ActionListener<ListDanglingIndicesResponse> listener)	List dangling indices on all nodes.
ActionFuture<ListTasksResponse>	listTasks(ListTasksRequest request)	List tasks
void	listTasks(ListTasksRequest request, ActionListener<ListTasksResponse> listener)	List active tasks
ActionFuture<NodesHotThreadsResponse>	nodesHotThreads(NodesHotThreadsRequest request)	Returns top N hot-threads samples per node.
void	nodesHotThreads(NodesHotThreadsRequest request, ActionListener<NodesHotThreadsResponse> listener)	Returns top N hot-threads samples per node.
ActionFuture<NodesInfoResponse>	nodesInfo(NodesInfoRequest request)	Nodes info of the cluster.
void	nodesInfo(NodesInfoRequest request, ActionListener<NodesInfoResponse> listener)	Nodes info of the cluster.
ActionFuture<NodesStatsResponse>	nodesStats(NodesStatsRequest request)	Nodes stats of the cluster.
void	nodesStats(NodesStatsRequest request, ActionListener<NodesStatsResponse> listener)	Nodes stats of the cluster.
ActionFuture<NodesUsageResponse>	nodesUsage(NodesUsageRequest request)	Returns top N hot-threads samples per node.
void	nodesUsage(NodesUsageRequest request, ActionListener<NodesUsageResponse> listener)	Nodes usage of the cluster.
ActionFuture<PendingClusterTasksResponse>	pendingClusterTasks(PendingClusterTasksRequest request)	Returns a list of the pending cluster tasks, that are scheduled to be executed.
void	pendingClusterTasks(PendingClusterTasksRequest request, ActionListener<PendingClusterTasksResponse> listener)	Returns a list of the pending cluster tasks, that are scheduled to be executed.
ClusterAllocationExplainRequestBuilder	prepareAllocationExplain()	Explain the allocation of a shard
CancelTasksRequestBuilder	prepareCancelTasks(String... nodesIds)	Cancel active tasks
CleanupRepositoryRequestBuilder	prepareCleanupRepository(String repository)	Cleans up repository.
CloneSnapshotRequestBuilder	prepareCloneSnapshot(String repository, String source, String target)	Clones a snapshot.
ClusterStatsRequestBuilder	prepareClusterStats()
CreateSnapshotRequestBuilder	prepareCreateSnapshot(String repository, String name)	Creates a new snapshot.
DeletePipelineRequestBuilder	prepareDeletePipeline()	Deletes a stored ingest pipeline
DeletePipelineRequestBuilder	prepareDeletePipeline(String id)	Deletes a stored ingest pipeline
DeleteRepositoryRequestBuilder	prepareDeleteRepository(String name)	Unregisters a repository.
DeleteSnapshotRequestBuilder	prepareDeleteSnapshot(String repository, String... snapshot)	Delete snapshot.
DeleteStoredScriptRequestBuilder	prepareDeleteStoredScript()	Delete a script from the cluster state
DeleteStoredScriptRequestBuilder	prepareDeleteStoredScript(String id)	Delete a script from the cluster state
GetPipelineRequestBuilder	prepareGetPipeline(String... ids)	Returns a stored ingest pipeline
GetRepositoriesRequestBuilder	prepareGetRepositories(String... name)	Gets repositories.
GetSnapshotsRequestBuilder	prepareGetSnapshots(String... repository)	Get snapshots.
GetStoredScriptRequestBuilder	prepareGetStoredScript()	Get a script from the cluster state
GetStoredScriptRequestBuilder	prepareGetStoredScript(String id)	Get a script from the cluster state
GetTaskRequestBuilder	prepareGetTask(String taskId)	Fetch a task by id.
GetTaskRequestBuilder	prepareGetTask(TaskId taskId)	Fetch a task by id.
ClusterHealthRequestBuilder	prepareHealth(String... indices)	The health of the cluster.
ListTasksRequestBuilder	prepareListTasks(String... nodesIds)	List active tasks
NodesHotThreadsRequestBuilder	prepareNodesHotThreads(String... nodesIds)	Returns a request builder to fetch top N hot-threads samples per node.
NodesInfoRequestBuilder	prepareNodesInfo(String... nodesIds)	Nodes info of the cluster.
NodesStatsRequestBuilder	prepareNodesStats(String... nodesIds)	Nodes stats of the cluster.
NodesUsageRequestBuilder	prepareNodesUsage(String... nodesIds)	Nodes usage of the cluster.
PendingClusterTasksRequestBuilder	preparePendingClusterTasks()	Returns a list of the pending cluster tasks, that are scheduled to be executed.
PutPipelineRequestBuilder	preparePutPipeline(String id, BytesReference source, org.elasticsearch.common.xcontent.XContentType xContentType)	Stores an ingest pipeline
PutRepositoryRequestBuilder	preparePutRepository(String name)	Registers a snapshot repository.
PutStoredScriptRequestBuilder	preparePutStoredScript()	Store a script in the cluster state
NodesReloadSecureSettingsRequestBuilder	prepareReloadSecureSettings()	Re initialize each cluster node and pass them the secret store password.
ClusterRerouteRequestBuilder	prepareReroute()	Update settings in the cluster.
RestoreSnapshotRequestBuilder	prepareRestoreSnapshot(String repository, String snapshot)	Restores a snapshot.
ClusterSearchShardsRequestBuilder	prepareSearchShards()	Returns list of shards the given search would be executed on.
ClusterSearchShardsRequestBuilder	prepareSearchShards(String... indices)	Returns list of shards the given search would be executed on.
SimulatePipelineRequestBuilder	prepareSimulatePipeline(BytesReference source, org.elasticsearch.common.xcontent.XContentType xContentType)	Simulates an ingest pipeline
SnapshotsStatusRequestBuilder	prepareSnapshotStatus()	Get snapshot status.
SnapshotsStatusRequestBuilder	prepareSnapshotStatus(String repository)	Get snapshot status.
ClusterStateRequestBuilder	prepareState()	The state of the cluster.
ClusterUpdateSettingsRequestBuilder	prepareUpdateSettings()	Update settings in the cluster.
VerifyRepositoryRequestBuilder	prepareVerifyRepository(String name)	Verifies a repository.
ActionFuture<AcknowledgedResponse>	putPipeline(PutPipelineRequest request)	Stores an ingest pipeline
void	putPipeline(PutPipelineRequest request, ActionListener<AcknowledgedResponse> listener)	Stores an ingest pipeline
ActionFuture<AcknowledgedResponse>	putRepository(PutRepositoryRequest request)	Registers a snapshot repository.
void	putRepository(PutRepositoryRequest request, ActionListener<AcknowledgedResponse> listener)	Registers a snapshot repository.
ActionFuture<AcknowledgedResponse>	putStoredScript(PutStoredScriptRequest request)	Store a script in the cluster state
void	putStoredScript(PutStoredScriptRequest request, ActionListener<AcknowledgedResponse> listener)	Store a script in the cluster state
ActionFuture<ClusterRerouteResponse>	reroute(ClusterRerouteRequest request)	Reroutes allocation of shards.
void	reroute(ClusterRerouteRequest request, ActionListener<ClusterRerouteResponse> listener)	Reroutes allocation of shards.
ActionFuture<RestoreSnapshotResponse>	restoreSnapshot(RestoreSnapshotRequest request)	Restores a snapshot.
void	restoreSnapshot(RestoreSnapshotRequest request, ActionListener<RestoreSnapshotResponse> listener)	Restores a snapshot.
ActionFuture<ClusterSearchShardsResponse>	searchShards(ClusterSearchShardsRequest request)	Returns list of shards the given search would be executed on.
void	searchShards(ClusterSearchShardsRequest request, ActionListener<ClusterSearchShardsResponse> listener)	Returns list of shards the given search would be executed on.
ActionFuture<SimulatePipelineResponse>	simulatePipeline(SimulatePipelineRequest request)	Simulates an ingest pipeline
void	simulatePipeline(SimulatePipelineRequest request, ActionListener<SimulatePipelineResponse> listener)	Simulates an ingest pipeline
ActionFuture<SnapshotsStatusResponse>	snapshotsStatus(SnapshotsStatusRequest request)	Get snapshot status.
void	snapshotsStatus(SnapshotsStatusRequest request, ActionListener<SnapshotsStatusResponse> listener)	Get snapshot status.
ActionFuture<ClusterStateResponse>	state(ClusterStateRequest request)	The state of the cluster.
void	state(ClusterStateRequest request, ActionListener<ClusterStateResponse> listener)	The state of the cluster.
ActionFuture<ClusterUpdateSettingsResponse>	updateSettings(ClusterUpdateSettingsRequest request)	Updates settings in the cluster.
void	updateSettings(ClusterUpdateSettingsRequest request, ActionListener<ClusterUpdateSettingsResponse> listener)	Update settings in the cluster.
ActionFuture<VerifyRepositoryResponse>	verifyRepository(VerifyRepositoryRequest request)	Verifies a repository.
void	verifyRepository(VerifyRepositoryRequest request, ActionListener<VerifyRepositoryResponse> listener)	Verifies a repository.

Methods inherited from interface org.elasticsearch.client.ElasticsearchClient

execute, execute, threadPool

Method Details

health

ActionFuture<ClusterHealthResponse> health(ClusterHealthRequest request)

The health of the cluster.

Parameters:

request - The cluster state request

Returns:

The result future

See Also:

Requests.clusterHealthRequest(String...)

health

void health(ClusterHealthRequest request,
 ActionListener<ClusterHealthResponse> listener)

The health of the cluster.

Parameters:

request - The cluster state request

listener - A listener to be notified with a result

See Also:

Requests.clusterHealthRequest(String...)

prepareHealth

ClusterHealthRequestBuilder prepareHealth(String... indices)

The health of the cluster.

state

ActionFuture<ClusterStateResponse> state(ClusterStateRequest request)

The state of the cluster.

Parameters:

request - The cluster state request.

Returns:

The result future

See Also:

Requests.clusterStateRequest()

state

void state(ClusterStateRequest request,
 ActionListener<ClusterStateResponse> listener)

The state of the cluster.

Parameters:

request - The cluster state request.

listener - A listener to be notified with a result

See Also:

Requests.clusterStateRequest()

prepareState

ClusterStateRequestBuilder prepareState()

The state of the cluster.

updateSettings

ActionFuture<ClusterUpdateSettingsResponse> updateSettings(ClusterUpdateSettingsRequest request)

Updates settings in the cluster.

updateSettings

void updateSettings(ClusterUpdateSettingsRequest request,
 ActionListener<ClusterUpdateSettingsResponse> listener)

Update settings in the cluster.

prepareUpdateSettings

ClusterUpdateSettingsRequestBuilder prepareUpdateSettings()

Update settings in the cluster.

prepareReloadSecureSettings

NodesReloadSecureSettingsRequestBuilder prepareReloadSecureSettings()

Re initialize each cluster node and pass them the secret store password.

reroute

ActionFuture<ClusterRerouteResponse> reroute(ClusterRerouteRequest request)

Reroutes allocation of shards. Advance API.

reroute

void reroute(ClusterRerouteRequest request,
 ActionListener<ClusterRerouteResponse> listener)

Reroutes allocation of shards. Advance API.

prepareReroute

ClusterRerouteRequestBuilder prepareReroute()

Update settings in the cluster.

nodesInfo

ActionFuture<NodesInfoResponse> nodesInfo(NodesInfoRequest request)

Nodes info of the cluster.

Parameters:

request - The nodes info request

Returns:

The result future

See Also:

Requests.nodesInfoRequest(String...)

nodesInfo

void nodesInfo(NodesInfoRequest request,
 ActionListener<NodesInfoResponse> listener)

Nodes info of the cluster.

Parameters:

request - The nodes info request

listener - A listener to be notified with a result

See Also:

Requests.nodesInfoRequest(String...)

prepareNodesInfo

NodesInfoRequestBuilder prepareNodesInfo(String... nodesIds)

Nodes info of the cluster.

clusterStats

ActionFuture<ClusterStatsResponse> clusterStats(ClusterStatsRequest request)

Cluster wide aggregated stats.

Parameters:

request - The cluster stats request

Returns:

The result future

See Also:

Requests.clusterStatsRequest()

clusterStats

void clusterStats(ClusterStatsRequest request,
 ActionListener<ClusterStatsResponse> listener)

Cluster wide aggregated stats

Parameters:

request - The cluster stats request

listener - A listener to be notified with a result

See Also:

Requests.clusterStatsRequest()

prepareClusterStats

ClusterStatsRequestBuilder prepareClusterStats()

nodesStats

ActionFuture<NodesStatsResponse> nodesStats(NodesStatsRequest request)

Nodes stats of the cluster.

Parameters:

request - The nodes stats request

Returns:

The result future

See Also:

Requests.nodesStatsRequest(String...)

nodesStats

void nodesStats(NodesStatsRequest request,
 ActionListener<NodesStatsResponse> listener)

Nodes stats of the cluster.

Parameters:

request - The nodes info request

listener - A listener to be notified with a result

See Also:

Requests.nodesStatsRequest(String...)

prepareNodesStats

NodesStatsRequestBuilder prepareNodesStats(String... nodesIds)

Nodes stats of the cluster.

nodesUsage

ActionFuture<NodesUsageResponse> nodesUsage(NodesUsageRequest request)

Returns top N hot-threads samples per node. The hot-threads are only sampled for the node ids specified in the request. Nodes usage of the cluster.

Parameters:

request - The nodes usage request

Returns:

The result future

See Also:

Requests.nodesUsageRequest(String...)

nodesUsage

void nodesUsage(NodesUsageRequest request,
 ActionListener<NodesUsageResponse> listener)

Nodes usage of the cluster.

Parameters:

request - The nodes usage request

listener - A listener to be notified with a result

See Also:

Requests.nodesUsageRequest(String...)

prepareNodesUsage

NodesUsageRequestBuilder prepareNodesUsage(String... nodesIds)

Nodes usage of the cluster.

nodesHotThreads

ActionFuture<NodesHotThreadsResponse> nodesHotThreads(NodesHotThreadsRequest request)

Returns top N hot-threads samples per node. The hot-threads are only sampled for the node ids specified in the request.

nodesHotThreads

void nodesHotThreads(NodesHotThreadsRequest request,
 ActionListener<NodesHotThreadsResponse> listener)

Returns top N hot-threads samples per node. The hot-threads are only sampled for the node ids specified in the request.

prepareNodesHotThreads

NodesHotThreadsRequestBuilder prepareNodesHotThreads(String... nodesIds)

Returns a request builder to fetch top N hot-threads samples per node. The hot-threads are only sampled for the node ids provided. Note: Use * to fetch samples for all nodes

listTasks

ActionFuture<ListTasksResponse> listTasks(ListTasksRequest request)

List tasks

Parameters:

request - The nodes tasks request

Returns:

The result future

See Also:

Requests.listTasksRequest()

listTasks

void listTasks(ListTasksRequest request,
 ActionListener<ListTasksResponse> listener)

List active tasks

Parameters:

request - The nodes tasks request

listener - A listener to be notified with a result

See Also:

Requests.listTasksRequest()

prepareListTasks

ListTasksRequestBuilder prepareListTasks(String... nodesIds)

List active tasks

getTask

ActionFuture<GetTaskResponse> getTask(GetTaskRequest request)

Get a task.

Parameters:

request - the request

Returns:

the result future

See Also:

Requests.getTaskRequest()

getTask

void getTask(GetTaskRequest request,
 ActionListener<GetTaskResponse> listener)

Get a task.

Parameters:

request - the request

listener - A listener to be notified with the result

See Also:

Requests.getTaskRequest()

prepareGetTask

GetTaskRequestBuilder prepareGetTask(String taskId)

Fetch a task by id.

prepareGetTask

GetTaskRequestBuilder prepareGetTask(TaskId taskId)

Fetch a task by id.

cancelTasks

ActionFuture<CancelTasksResponse> cancelTasks(CancelTasksRequest request)

Cancel tasks

Parameters:

request - The nodes tasks request

Returns:

The result future

See Also:

Requests.cancelTasksRequest()

cancelTasks

void cancelTasks(CancelTasksRequest request,
 ActionListener<CancelTasksResponse> listener)

Cancel active tasks

Parameters:

request - The nodes tasks request

listener - A listener to be notified with a result

See Also:

Requests.cancelTasksRequest()

prepareCancelTasks

CancelTasksRequestBuilder prepareCancelTasks(String... nodesIds)

Cancel active tasks

searchShards

ActionFuture<ClusterSearchShardsResponse> searchShards(ClusterSearchShardsRequest request)

Returns list of shards the given search would be executed on.

searchShards

void searchShards(ClusterSearchShardsRequest request,
 ActionListener<ClusterSearchShardsResponse> listener)

Returns list of shards the given search would be executed on.

prepareSearchShards

ClusterSearchShardsRequestBuilder prepareSearchShards()

Returns list of shards the given search would be executed on.

prepareSearchShards

ClusterSearchShardsRequestBuilder prepareSearchShards(String... indices)

Returns list of shards the given search would be executed on.

putRepository

ActionFuture<AcknowledgedResponse> putRepository(PutRepositoryRequest request)

Registers a snapshot repository.

putRepository

void putRepository(PutRepositoryRequest request,
 ActionListener<AcknowledgedResponse> listener)

Registers a snapshot repository.

preparePutRepository

PutRepositoryRequestBuilder preparePutRepository(String name)

Registers a snapshot repository.

deleteRepository

ActionFuture<AcknowledgedResponse> deleteRepository(DeleteRepositoryRequest request)

Unregisters a repository.

deleteRepository

void deleteRepository(DeleteRepositoryRequest request,
 ActionListener<AcknowledgedResponse> listener)

Unregisters a repository.

prepareDeleteRepository

DeleteRepositoryRequestBuilder prepareDeleteRepository(String name)

Unregisters a repository.

getRepositories

ActionFuture<GetRepositoriesResponse> getRepositories(GetRepositoriesRequest request)

Gets repositories.

getRepositories

void getRepositories(GetRepositoriesRequest request,
 ActionListener<GetRepositoriesResponse> listener)

Gets repositories.

prepareGetRepositories

GetRepositoriesRequestBuilder prepareGetRepositories(String... name)

Gets repositories.

prepareCleanupRepository

CleanupRepositoryRequestBuilder prepareCleanupRepository(String repository)

Cleans up repository.

cleanupRepository

ActionFuture<CleanupRepositoryResponse> cleanupRepository(CleanupRepositoryRequest repository)

Cleans up repository.

cleanupRepository

void cleanupRepository(CleanupRepositoryRequest repository,
 ActionListener<CleanupRepositoryResponse> listener)

Cleans up repository.

verifyRepository

ActionFuture<VerifyRepositoryResponse> verifyRepository(VerifyRepositoryRequest request)

Verifies a repository.

verifyRepository

void verifyRepository(VerifyRepositoryRequest request,
 ActionListener<VerifyRepositoryResponse> listener)

Verifies a repository.

prepareVerifyRepository

VerifyRepositoryRequestBuilder prepareVerifyRepository(String name)

Verifies a repository.

createSnapshot

ActionFuture<CreateSnapshotResponse> createSnapshot(CreateSnapshotRequest request)

Creates a new snapshot.

createSnapshot

void createSnapshot(CreateSnapshotRequest request,
 ActionListener<CreateSnapshotResponse> listener)

Creates a new snapshot.

prepareCreateSnapshot

CreateSnapshotRequestBuilder prepareCreateSnapshot(String repository,
 String name)

Creates a new snapshot.

prepareCloneSnapshot

CloneSnapshotRequestBuilder prepareCloneSnapshot(String repository,
 String source,
 String target)

Clones a snapshot.

cloneSnapshot

ActionFuture<AcknowledgedResponse> cloneSnapshot(CloneSnapshotRequest request)

Clones a snapshot.

cloneSnapshot

void cloneSnapshot(CloneSnapshotRequest request,
 ActionListener<AcknowledgedResponse> listener)

Clones a snapshot.

getSnapshots

ActionFuture<GetSnapshotsResponse> getSnapshots(GetSnapshotsRequest request)

Get snapshots.

getSnapshots

void getSnapshots(GetSnapshotsRequest request,
 ActionListener<GetSnapshotsResponse> listener)

Get snapshots.

prepareGetSnapshots

GetSnapshotsRequestBuilder prepareGetSnapshots(String... repository)

Get snapshots.

deleteSnapshot

ActionFuture<AcknowledgedResponse> deleteSnapshot(DeleteSnapshotRequest request)

Delete snapshot.

deleteSnapshot

void deleteSnapshot(DeleteSnapshotRequest request,
 ActionListener<AcknowledgedResponse> listener)

Delete snapshot.

prepareDeleteSnapshot

DeleteSnapshotRequestBuilder prepareDeleteSnapshot(String repository,
 String... snapshot)

Delete snapshot.

restoreSnapshot

ActionFuture<RestoreSnapshotResponse> restoreSnapshot(RestoreSnapshotRequest request)

Restores a snapshot.

restoreSnapshot

void restoreSnapshot(RestoreSnapshotRequest request,
 ActionListener<RestoreSnapshotResponse> listener)

Restores a snapshot.

prepareRestoreSnapshot

RestoreSnapshotRequestBuilder prepareRestoreSnapshot(String repository,
 String snapshot)

Restores a snapshot.

pendingClusterTasks

void pendingClusterTasks(PendingClusterTasksRequest request,
 ActionListener<PendingClusterTasksResponse> listener)

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

pendingClusterTasks

ActionFuture<PendingClusterTasksResponse> pendingClusterTasks(PendingClusterTasksRequest request)

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

preparePendingClusterTasks

PendingClusterTasksRequestBuilder preparePendingClusterTasks()

Returns a list of the pending cluster tasks, that are scheduled to be executed. This includes operations that update the cluster state (for example, a create index operation)

snapshotsStatus

ActionFuture<SnapshotsStatusResponse> snapshotsStatus(SnapshotsStatusRequest request)

Get snapshot status.

snapshotsStatus

void snapshotsStatus(SnapshotsStatusRequest request,
 ActionListener<SnapshotsStatusResponse> listener)

Get snapshot status.

prepareSnapshotStatus

SnapshotsStatusRequestBuilder prepareSnapshotStatus(String repository)

Get snapshot status.

prepareSnapshotStatus

SnapshotsStatusRequestBuilder prepareSnapshotStatus()

Get snapshot status.

putPipeline

void putPipeline(PutPipelineRequest request,
 ActionListener<AcknowledgedResponse> listener)

Stores an ingest pipeline

putPipeline

ActionFuture<AcknowledgedResponse> putPipeline(PutPipelineRequest request)

Stores an ingest pipeline

preparePutPipeline

PutPipelineRequestBuilder preparePutPipeline(String id,
 BytesReference source,
 org.elasticsearch.common.xcontent.XContentType xContentType)

Stores an ingest pipeline

deletePipeline

void deletePipeline(DeletePipelineRequest request,
 ActionListener<AcknowledgedResponse> listener)

Deletes a stored ingest pipeline

deletePipeline

ActionFuture<AcknowledgedResponse> deletePipeline(DeletePipelineRequest request)

Deletes a stored ingest pipeline

prepareDeletePipeline

DeletePipelineRequestBuilder prepareDeletePipeline()

Deletes a stored ingest pipeline

prepareDeletePipeline

DeletePipelineRequestBuilder prepareDeletePipeline(String id)

Deletes a stored ingest pipeline

getPipeline

void getPipeline(GetPipelineRequest request,
 ActionListener<GetPipelineResponse> listener)

Returns a stored ingest pipeline

getPipeline

ActionFuture<GetPipelineResponse> getPipeline(GetPipelineRequest request)

Returns a stored ingest pipeline

prepareGetPipeline

GetPipelineRequestBuilder prepareGetPipeline(String... ids)

Returns a stored ingest pipeline

simulatePipeline

void simulatePipeline(SimulatePipelineRequest request,
 ActionListener<SimulatePipelineResponse> listener)

Simulates an ingest pipeline

simulatePipeline

ActionFuture<SimulatePipelineResponse> simulatePipeline(SimulatePipelineRequest request)

Simulates an ingest pipeline

prepareSimulatePipeline

SimulatePipelineRequestBuilder prepareSimulatePipeline(BytesReference source,
 org.elasticsearch.common.xcontent.XContentType xContentType)

Simulates an ingest pipeline

allocationExplain

void allocationExplain(ClusterAllocationExplainRequest request,
 ActionListener<ClusterAllocationExplainResponse> listener)

Explain the allocation of a shard

allocationExplain

ActionFuture<ClusterAllocationExplainResponse> allocationExplain(ClusterAllocationExplainRequest request)

Explain the allocation of a shard

prepareAllocationExplain

ClusterAllocationExplainRequestBuilder prepareAllocationExplain()

Explain the allocation of a shard

preparePutStoredScript

PutStoredScriptRequestBuilder preparePutStoredScript()

Store a script in the cluster state

deleteStoredScript

void deleteStoredScript(DeleteStoredScriptRequest request,
 ActionListener<AcknowledgedResponse> listener)

Delete a script from the cluster state

deleteStoredScript

ActionFuture<AcknowledgedResponse> deleteStoredScript(DeleteStoredScriptRequest request)

Delete a script from the cluster state

prepareDeleteStoredScript

DeleteStoredScriptRequestBuilder prepareDeleteStoredScript()

Delete a script from the cluster state

prepareDeleteStoredScript

DeleteStoredScriptRequestBuilder prepareDeleteStoredScript(String id)

Delete a script from the cluster state

putStoredScript

void putStoredScript(PutStoredScriptRequest request,
 ActionListener<AcknowledgedResponse> listener)

Store a script in the cluster state

putStoredScript

ActionFuture<AcknowledgedResponse> putStoredScript(PutStoredScriptRequest request)

Store a script in the cluster state

prepareGetStoredScript

GetStoredScriptRequestBuilder prepareGetStoredScript()

Get a script from the cluster state

prepareGetStoredScript

GetStoredScriptRequestBuilder prepareGetStoredScript(String id)

Get a script from the cluster state

getStoredScript

void getStoredScript(GetStoredScriptRequest request,
 ActionListener<GetStoredScriptResponse> listener)

Get a script from the cluster state

getStoredScript

ActionFuture<GetStoredScriptResponse> getStoredScript(GetStoredScriptRequest request)

Get a script from the cluster state

listDanglingIndices

void listDanglingIndices(ListDanglingIndicesRequest request,
 ActionListener<ListDanglingIndicesResponse> listener)

List dangling indices on all nodes.

listDanglingIndices

ActionFuture<ListDanglingIndicesResponse> listDanglingIndices(ListDanglingIndicesRequest request)

List dangling indices on all nodes.

importDanglingIndex

void importDanglingIndex(ImportDanglingIndexRequest request,
 ActionListener<AcknowledgedResponse> listener)

Restore specified dangling indices.

importDanglingIndex

ActionFuture<AcknowledgedResponse> importDanglingIndex(ImportDanglingIndexRequest request)

Restore specified dangling indices.

deleteDanglingIndex

void deleteDanglingIndex(DeleteDanglingIndexRequest request,
 ActionListener<AcknowledgedResponse> listener)

Delete specified dangling indices.

deleteDanglingIndex

ActionFuture<AcknowledgedResponse> deleteDanglingIndex(DeleteDanglingIndexRequest request)

Delete specified dangling indices.