java.lang.Object
org.elasticsearch.client.internal.ClusterAdminClient
- All Implemented Interfaces:
ElasticsearchClient
Administrative actions/operations against indices.
- See Also:
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncancelTasks(CancelTasksRequest request) voidcancelTasks(CancelTasksRequest request, ActionListener<ListTasksResponse> listener) voidcleanupRepository(CleanupRepositoryRequest request, ActionListener<CleanupRepositoryResponse> listener) voidcloneSnapshot(CloneSnapshotRequest request, ActionListener<AcknowledgedResponse> listener) voidclusterStats(ClusterStatsRequest request, ActionListener<ClusterStatsResponse> listener) createSnapshot(CreateSnapshotRequest request) voidcreateSnapshot(CreateSnapshotRequest request, ActionListener<CreateSnapshotResponse> listener) deletePipeline(DeletePipelineRequest request) voiddeletePipeline(DeletePipelineRequest request, ActionListener<AcknowledgedResponse> listener) voiddeleteRepository(DeleteRepositoryRequest request, ActionListener<AcknowledgedResponse> listener) voiddeleteSnapshot(DeleteSnapshotRequest request, ActionListener<AcknowledgedResponse> listener) <Request extends ActionRequest,Response extends ActionResponse>
ActionFuture<Response> execute(ActionType<Response> action, Request request) Executes a generic action, denoted by anActionType.<Request extends ActionRequest,Response extends ActionResponse>
voidexecute(ActionType<Response> action, Request request, ActionListener<Response> listener) Executes a generic action, denoted by anActionType.voidgetPipeline(GetPipelineRequest request, ActionListener<GetPipelineResponse> listener) voidgetRepositories(GetRepositoriesRequest request, ActionListener<GetRepositoriesResponse> listener) voidgetSnapshots(GetSnapshotsRequest request, ActionListener<GetSnapshotsResponse> listener) getTask(GetTaskRequest request) voidgetTask(GetTaskRequest request, ActionListener<GetTaskResponse> listener) health(ClusterHealthRequest request) voidhealth(ClusterHealthRequest request, ActionListener<ClusterHealthResponse> listener) listTasks(ListTasksRequest request) voidlistTasks(ListTasksRequest request, ActionListener<ListTasksResponse> listener) voidnodesCapabilities(NodesCapabilitiesRequest request, ActionListener<NodesCapabilitiesResponse> listener) nodesInfo(NodesInfoRequest request) voidnodesInfo(NodesInfoRequest request, ActionListener<NodesInfoResponse> listener) nodesStats(NodesStatsRequest request) voidnodesStats(NodesStatsRequest request, ActionListener<NodesStatsResponse> listener) voidnodesUsage(NodesUsageRequest request, ActionListener<NodesUsageResponse> listener) prepareCancelTasks(String... nodesIds) prepareCleanupRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String repository) prepareCloneSnapshot(TimeValue masterNodeTimeout, String repository, String source, String target) prepareCreateSnapshot(TimeValue masterNodeTimeout, String repository, String name) prepareDeleteRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) prepareDeleteSnapshot(TimeValue masterNodeTimeout, String repository, String... names) prepareGetPipeline(String... ids) prepareGetRepositories(TimeValue masterNodeTimeout, String... name) prepareGetSnapshots(TimeValue masterNodeTimeout, String... repositories) prepareGetTask(String taskId) prepareGetTask(TaskId taskId) prepareHealth(TimeValue masterNodeTimeout, String... indices) prepareListTasks(String... nodesIds) prepareNodesInfo(String... nodesIds) prepareNodesStats(String... nodesIds) preparePutPipeline(String id, BytesReference source, XContentType xContentType) preparePutRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) prepareRestoreSnapshot(TimeValue masterNodeTimeout, String repository, String snapshot) prepareSimulatePipeline(BytesReference source, XContentType xContentType) prepareSnapshotStatus(TimeValue masterNodeTimeout) prepareSnapshotStatus(TimeValue masterNodeTimeout, String repository) prepareState(TimeValue masterNodeTimeout) prepareUpdateSettings(TimeValue masterNodeTimeout, TimeValue ackTimeout) prepareVerifyRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) putPipeline(PutPipelineRequest request) voidputPipeline(PutPipelineRequest request, ActionListener<AcknowledgedResponse> listener) voidputRepository(PutRepositoryRequest request, ActionListener<AcknowledgedResponse> listener) restoreSnapshot(RestoreSnapshotRequest request) voidrestoreSnapshot(RestoreSnapshotRequest request, ActionListener<RestoreSnapshotResponse> listener) simulatePipeline(SimulatePipelineRequest request) voidsimulatePipeline(SimulatePipelineRequest request, ActionListener<SimulatePipelineResponse> listener) voidsnapshotsStatus(SnapshotsStatusRequest request, ActionListener<SnapshotsStatusResponse> listener) state(ClusterStateRequest request) voidstate(ClusterStateRequest request, ActionListener<ClusterStateResponse> listener) Returns the threadpool used to execute requests on this clientvoidupdateSettings(ClusterUpdateSettingsRequest request, ActionListener<ClusterUpdateSettingsResponse> listener) voidverifyRepository(VerifyRepositoryRequest request, ActionListener<VerifyRepositoryResponse> listener)
-
Field Details
-
client
-
-
Constructor Details
-
ClusterAdminClient
-
-
Method Details
-
execute
public <Request extends ActionRequest,Response extends ActionResponse> ActionFuture<Response> execute(ActionType<Response> action, Request request) Description copied from interface:ElasticsearchClientExecutes a generic action, denoted by anActionType.- Specified by:
executein interfaceElasticsearchClient- Type Parameters:
Request- The request type.Response- the response type.- Parameters:
action- The action type to execute.request- The action request.- Returns:
- A future allowing to get back the response.
-
execute
public <Request extends ActionRequest,Response extends ActionResponse> void execute(ActionType<Response> action, Request request, ActionListener<Response> listener) Description copied from interface:ElasticsearchClientExecutes a generic action, denoted by anActionType.- Specified by:
executein interfaceElasticsearchClient- Type Parameters:
Request- The request type.Response- The response type.- Parameters:
action- The action type to execute.request- The action request.listener- The listener to receive the response back.
-
threadPool
Description copied from interface:ElasticsearchClientReturns the threadpool used to execute requests on this client- Specified by:
threadPoolin interfaceElasticsearchClient
-
health
-
health
-
prepareHealth
-
state
-
state
-
prepareState
-
updateSettings
public ActionFuture<ClusterUpdateSettingsResponse> updateSettings(ClusterUpdateSettingsRequest request) -
updateSettings
public void updateSettings(ClusterUpdateSettingsRequest request, ActionListener<ClusterUpdateSettingsResponse> listener) -
prepareUpdateSettings
public ClusterUpdateSettingsRequestBuilder prepareUpdateSettings(TimeValue masterNodeTimeout, TimeValue ackTimeout) -
nodesInfo
-
nodesInfo
-
prepareNodesInfo
-
clusterStats
public void clusterStats(ClusterStatsRequest request, ActionListener<ClusterStatsResponse> listener) -
prepareClusterStats
-
nodesStats
-
nodesStats
-
prepareNodesStats
-
nodesCapabilities
-
nodesCapabilities
public void nodesCapabilities(NodesCapabilitiesRequest request, ActionListener<NodesCapabilitiesResponse> listener) -
nodesUsage
-
listTasks
-
listTasks
-
prepareListTasks
-
getTask
-
getTask
-
prepareGetTask
-
prepareGetTask
-
cancelTasks
-
cancelTasks
-
prepareCancelTasks
-
putRepository
public void putRepository(PutRepositoryRequest request, ActionListener<AcknowledgedResponse> listener) -
preparePutRepository
public PutRepositoryRequestBuilder preparePutRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) -
deleteRepository
public void deleteRepository(DeleteRepositoryRequest request, ActionListener<AcknowledgedResponse> listener) -
prepareDeleteRepository
public DeleteRepositoryRequestBuilder prepareDeleteRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) -
getRepositories
public void getRepositories(GetRepositoriesRequest request, ActionListener<GetRepositoriesResponse> listener) -
prepareGetRepositories
public GetRepositoriesRequestBuilder prepareGetRepositories(TimeValue masterNodeTimeout, String... name) -
prepareCleanupRepository
public CleanupRepositoryRequestBuilder prepareCleanupRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String repository) -
cleanupRepository
public void cleanupRepository(CleanupRepositoryRequest request, ActionListener<CleanupRepositoryResponse> listener) -
verifyRepository
public void verifyRepository(VerifyRepositoryRequest request, ActionListener<VerifyRepositoryResponse> listener) -
prepareVerifyRepository
public VerifyRepositoryRequestBuilder prepareVerifyRepository(TimeValue masterNodeTimeout, TimeValue ackTimeout, String name) -
createSnapshot
-
createSnapshot
public void createSnapshot(CreateSnapshotRequest request, ActionListener<CreateSnapshotResponse> listener) -
prepareCreateSnapshot
public CreateSnapshotRequestBuilder prepareCreateSnapshot(TimeValue masterNodeTimeout, String repository, String name) -
prepareCloneSnapshot
public CloneSnapshotRequestBuilder prepareCloneSnapshot(TimeValue masterNodeTimeout, String repository, String source, String target) -
cloneSnapshot
public void cloneSnapshot(CloneSnapshotRequest request, ActionListener<AcknowledgedResponse> listener) -
getSnapshots
public void getSnapshots(GetSnapshotsRequest request, ActionListener<GetSnapshotsResponse> listener) -
prepareGetSnapshots
public GetSnapshotsRequestBuilder prepareGetSnapshots(TimeValue masterNodeTimeout, String... repositories) -
deleteSnapshot
public void deleteSnapshot(DeleteSnapshotRequest request, ActionListener<AcknowledgedResponse> listener) -
prepareDeleteSnapshot
public DeleteSnapshotRequestBuilder prepareDeleteSnapshot(TimeValue masterNodeTimeout, String repository, String... names) -
restoreSnapshot
-
restoreSnapshot
public void restoreSnapshot(RestoreSnapshotRequest request, ActionListener<RestoreSnapshotResponse> listener) -
prepareRestoreSnapshot
public RestoreSnapshotRequestBuilder prepareRestoreSnapshot(TimeValue masterNodeTimeout, String repository, String snapshot) -
snapshotsStatus
public void snapshotsStatus(SnapshotsStatusRequest request, ActionListener<SnapshotsStatusResponse> listener) -
prepareSnapshotStatus
public SnapshotsStatusRequestBuilder prepareSnapshotStatus(TimeValue masterNodeTimeout, String repository) -
prepareSnapshotStatus
-
putPipeline
-
putPipeline
-
preparePutPipeline
public PutPipelineRequestBuilder preparePutPipeline(String id, BytesReference source, XContentType xContentType) -
deletePipeline
public void deletePipeline(DeletePipelineRequest request, ActionListener<AcknowledgedResponse> listener) -
deletePipeline
-
prepareDeletePipeline
-
getPipeline
-
prepareGetPipeline
-
simulatePipeline
public void simulatePipeline(SimulatePipelineRequest request, ActionListener<SimulatePipelineResponse> listener) -
simulatePipeline
-
prepareSimulatePipeline
public SimulatePipelineRequestBuilder prepareSimulatePipeline(BytesReference source, XContentType xContentType)
-