Modifier and Type | Class and Description |
---|---|
class |
LatchedActionListener<T>
An action listener that allows passing in a
CountDownLatch that
will be counted down after onResponse or onFailure is called |
Modifier and Type | Field and Description |
---|---|
protected ActionListener<Response> |
ActionRunnable.listener |
Modifier and Type | Method and Description |
---|---|
void |
ListenableActionFuture.addListener(ActionListener<T> listener)
Add an action listener to be invoked when a response has received.
|
protected abstract void |
ActionRequestBuilder.doExecute(ActionListener<Response> listener) |
void |
ActionRequestBuilder.execute(ActionListener<Response> listener) |
void |
TransportActionNodeProxy.execute(DiscoveryNode node,
Request request,
ActionListener<Response> listener) |
Constructor and Description |
---|
ActionRunnable(ActionListener<Response> listener) |
LatchedActionListener(ActionListener<T> delegate,
CountDownLatch latch) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterHealthRequestBuilder.doExecute(ActionListener<ClusterHealthResponse> listener) |
protected void |
TransportClusterHealthAction.masterOperation(ClusterHealthRequest request,
ClusterState unusedState,
ActionListener<ClusterHealthResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
NodesHotThreadsRequestBuilder.doExecute(ActionListener<NodesHotThreadsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
NodesInfoRequestBuilder.doExecute(ActionListener<NodesInfoResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
NodesRestartRequestBuilder.doExecute(ActionListener<NodesRestartResponse> listener) |
protected void |
TransportNodesRestartAction.doExecute(NodesRestartRequest nodesRestartRequest,
ActionListener<NodesRestartResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
NodesShutdownRequestBuilder.doExecute(ActionListener<NodesShutdownResponse> listener) |
protected void |
TransportNodesShutdownAction.masterOperation(NodesShutdownRequest request,
ClusterState state,
ActionListener<NodesShutdownResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
NodesStatsRequestBuilder.doExecute(ActionListener<NodesStatsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteRepositoryRequestBuilder.doExecute(ActionListener<DeleteRepositoryResponse> listener) |
protected void |
TransportDeleteRepositoryAction.masterOperation(DeleteRepositoryRequest request,
ClusterState state,
ActionListener<DeleteRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetRepositoriesRequestBuilder.doExecute(ActionListener<GetRepositoriesResponse> listener) |
protected void |
TransportGetRepositoriesAction.masterOperation(GetRepositoriesRequest request,
ClusterState state,
ActionListener<GetRepositoriesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutRepositoryRequestBuilder.doExecute(ActionListener<PutRepositoryResponse> listener) |
protected void |
TransportPutRepositoryAction.masterOperation(PutRepositoryRequest request,
ClusterState state,
ActionListener<PutRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
VerifyRepositoryRequestBuilder.doExecute(ActionListener<VerifyRepositoryResponse> listener) |
protected void |
TransportVerifyRepositoryAction.masterOperation(VerifyRepositoryRequest request,
ClusterState state,
ActionListener<VerifyRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterRerouteRequestBuilder.doExecute(ActionListener<ClusterRerouteResponse> listener) |
protected void |
TransportClusterRerouteAction.masterOperation(ClusterRerouteRequest request,
ClusterState state,
ActionListener<ClusterRerouteResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterUpdateSettingsRequestBuilder.doExecute(ActionListener<ClusterUpdateSettingsResponse> listener) |
protected void |
TransportClusterUpdateSettingsAction.masterOperation(ClusterUpdateSettingsRequest request,
ClusterState state,
ActionListener<ClusterUpdateSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterSearchShardsRequestBuilder.doExecute(ActionListener<ClusterSearchShardsResponse> listener) |
protected void |
TransportClusterSearchShardsAction.masterOperation(ClusterSearchShardsRequest request,
ClusterState state,
ActionListener<ClusterSearchShardsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
CreateSnapshotRequestBuilder.doExecute(ActionListener<CreateSnapshotResponse> listener) |
protected void |
TransportCreateSnapshotAction.masterOperation(CreateSnapshotRequest request,
ClusterState state,
ActionListener<CreateSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteSnapshotRequestBuilder.doExecute(ActionListener<DeleteSnapshotResponse> listener) |
protected void |
TransportDeleteSnapshotAction.masterOperation(DeleteSnapshotRequest request,
ClusterState state,
ActionListener<DeleteSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetSnapshotsRequestBuilder.doExecute(ActionListener<GetSnapshotsResponse> listener) |
protected void |
TransportGetSnapshotsAction.masterOperation(GetSnapshotsRequest request,
ClusterState state,
ActionListener<GetSnapshotsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
RestoreSnapshotRequestBuilder.doExecute(ActionListener<RestoreSnapshotResponse> listener) |
protected void |
TransportRestoreSnapshotAction.masterOperation(RestoreSnapshotRequest request,
ClusterState state,
ActionListener<RestoreSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
SnapshotsStatusRequestBuilder.doExecute(ActionListener<SnapshotsStatusResponse> listener) |
protected void |
TransportSnapshotsStatusAction.masterOperation(SnapshotsStatusRequest request,
ClusterState state,
ActionListener<SnapshotsStatusResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterStateRequestBuilder.doExecute(ActionListener<ClusterStateResponse> listener) |
protected void |
TransportClusterStateAction.masterOperation(ClusterStateRequest request,
ClusterState state,
ActionListener<ClusterStateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClusterStatsRequestBuilder.doExecute(ActionListener<ClusterStatsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PendingClusterTasksRequestBuilder.doExecute(ActionListener<PendingClusterTasksResponse> listener) |
protected void |
TransportPendingClusterTasksAction.masterOperation(PendingClusterTasksRequest request,
ClusterState state,
ActionListener<PendingClusterTasksResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndicesAliasesRequestBuilder.doExecute(ActionListener<IndicesAliasesResponse> listener) |
protected void |
TransportIndicesAliasesAction.masterOperation(IndicesAliasesRequest request,
ClusterState state,
ActionListener<IndicesAliasesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
AliasesExistRequestBuilder.doExecute(ActionListener<AliasesExistResponse> listener) |
protected void |
TransportAliasesExistAction.masterOperation(GetAliasesRequest request,
ClusterState state,
ActionListener<AliasesExistResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetAliasesRequestBuilder.doExecute(ActionListener<GetAliasesResponse> listener) |
protected void |
TransportGetAliasesAction.masterOperation(GetAliasesRequest request,
ClusterState state,
ActionListener<GetAliasesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
AnalyzeRequestBuilder.doExecute(ActionListener<AnalyzeResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClearIndicesCacheRequestBuilder.doExecute(ActionListener<ClearIndicesCacheResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
CloseIndexRequestBuilder.doExecute(ActionListener<CloseIndexResponse> listener) |
protected void |
TransportCloseIndexAction.doExecute(CloseIndexRequest request,
ActionListener<CloseIndexResponse> listener) |
protected void |
TransportCloseIndexAction.masterOperation(CloseIndexRequest request,
ClusterState state,
ActionListener<CloseIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
CreateIndexRequestBuilder.doExecute(ActionListener<CreateIndexResponse> listener) |
protected void |
TransportCreateIndexAction.masterOperation(CreateIndexRequest request,
ClusterState state,
ActionListener<CreateIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteIndexRequestBuilder.doExecute(ActionListener<DeleteIndexResponse> listener) |
protected void |
TransportDeleteIndexAction.doExecute(DeleteIndexRequest request,
ActionListener<DeleteIndexResponse> listener) |
protected void |
TransportDeleteIndexAction.masterOperation(DeleteIndexRequest request,
ClusterState state,
ActionListener<DeleteIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndicesExistsRequestBuilder.doExecute(ActionListener<IndicesExistsResponse> listener) |
protected void |
TransportIndicesExistsAction.masterOperation(IndicesExistsRequest request,
ClusterState state,
ActionListener<IndicesExistsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TypesExistsRequestBuilder.doExecute(ActionListener<TypesExistsResponse> listener) |
protected void |
TransportTypesExistsAction.masterOperation(TypesExistsRequest request,
ClusterState state,
ActionListener<TypesExistsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
FlushRequestBuilder.doExecute(ActionListener<FlushResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetIndexRequestBuilder.doExecute(ActionListener<GetIndexResponse> listener) |
protected void |
TransportGetIndexAction.doMasterOperation(GetIndexRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteMappingRequestBuilder.doExecute(ActionListener<DeleteMappingResponse> listener) |
protected void |
TransportDeleteMappingAction.doExecute(DeleteMappingRequest request,
ActionListener<DeleteMappingResponse> listener) |
protected void |
TransportDeleteMappingAction.masterOperation(DeleteMappingRequest request,
ClusterState state,
ActionListener<DeleteMappingResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetFieldMappingsRequestBuilder.doExecute(ActionListener<GetFieldMappingsResponse> listener) |
protected void |
GetMappingsRequestBuilder.doExecute(ActionListener<GetMappingsResponse> listener) |
protected void |
TransportGetFieldMappingsAction.doExecute(GetFieldMappingsRequest request,
ActionListener<GetFieldMappingsResponse> listener) |
protected void |
TransportGetMappingsAction.doMasterOperation(GetMappingsRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetMappingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutMappingRequestBuilder.doExecute(ActionListener<PutMappingResponse> listener) |
protected void |
TransportPutMappingAction.masterOperation(PutMappingRequest request,
ClusterState state,
ActionListener<PutMappingResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
OpenIndexRequestBuilder.doExecute(ActionListener<OpenIndexResponse> listener) |
protected void |
TransportOpenIndexAction.doExecute(OpenIndexRequest request,
ActionListener<OpenIndexResponse> listener) |
protected void |
TransportOpenIndexAction.masterOperation(OpenIndexRequest request,
ClusterState state,
ActionListener<OpenIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
OptimizeRequestBuilder.doExecute(ActionListener<OptimizeResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
RecoveryRequestBuilder.doExecute(ActionListener<RecoveryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
RefreshRequestBuilder.doExecute(ActionListener<RefreshResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndicesSegmentsRequestBuilder.doExecute(ActionListener<IndicesSegmentResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetSettingsRequestBuilder.doExecute(ActionListener<GetSettingsResponse> listener) |
protected void |
TransportGetSettingsAction.masterOperation(GetSettingsRequest request,
ClusterState state,
ActionListener<GetSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
UpdateSettingsRequestBuilder.doExecute(ActionListener<UpdateSettingsResponse> listener) |
protected void |
TransportUpdateSettingsAction.masterOperation(UpdateSettingsRequest request,
ClusterState state,
ActionListener<UpdateSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndicesStatsRequestBuilder.doExecute(ActionListener<IndicesStatsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndicesStatusRequestBuilder.doExecute(ActionListener<IndicesStatusResponse> listener)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteIndexTemplateRequestBuilder.doExecute(ActionListener<DeleteIndexTemplateResponse> listener) |
protected void |
TransportDeleteIndexTemplateAction.masterOperation(DeleteIndexTemplateRequest request,
ClusterState state,
ActionListener<DeleteIndexTemplateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetIndexTemplatesRequestBuilder.doExecute(ActionListener<GetIndexTemplatesResponse> listener) |
protected void |
TransportGetIndexTemplatesAction.masterOperation(GetIndexTemplatesRequest request,
ClusterState state,
ActionListener<GetIndexTemplatesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutIndexTemplateRequestBuilder.doExecute(ActionListener<PutIndexTemplateResponse> listener) |
protected void |
TransportPutIndexTemplateAction.masterOperation(PutIndexTemplateRequest request,
ClusterState state,
ActionListener<PutIndexTemplateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ValidateQueryRequestBuilder.doExecute(ActionListener<ValidateQueryResponse> listener) |
protected void |
TransportValidateQueryAction.doExecute(ValidateQueryRequest request,
ActionListener<ValidateQueryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteWarmerRequestBuilder.doExecute(ActionListener<DeleteWarmerResponse> listener) |
protected void |
TransportDeleteWarmerAction.masterOperation(DeleteWarmerRequest request,
ClusterState state,
ActionListener<DeleteWarmerResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetWarmersRequestBuilder.doExecute(ActionListener<GetWarmersResponse> listener) |
protected void |
TransportGetWarmersAction.doMasterOperation(GetWarmersRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetWarmersResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutWarmerRequestBuilder.doExecute(ActionListener<PutWarmerResponse> listener) |
protected void |
TransportPutWarmerAction.masterOperation(PutWarmerRequest request,
ClusterState state,
ActionListener<PutWarmerResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
BulkRequestBuilder.doExecute(ActionListener<BulkResponse> listener) |
protected void |
TransportBulkAction.doExecute(BulkRequest bulkRequest,
ActionListener<BulkResponse> listener) |
void |
TransportBulkAction.executeBulk(BulkRequest bulkRequest,
ActionListener<BulkResponse> listener)
This method executes the
BulkRequest and calls the given listener once the request returns. |
Modifier and Type | Method and Description |
---|---|
protected void |
CountRequestBuilder.doExecute(ActionListener<CountResponse> listener) |
protected void |
TransportCountAction.doExecute(CountRequest request,
ActionListener<CountResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteRequestBuilder.doExecute(ActionListener<DeleteResponse> listener) |
protected void |
TransportDeleteAction.doExecute(DeleteRequest request,
ActionListener<DeleteResponse> listener) |
protected boolean |
TransportDeleteAction.resolveRequest(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request,
ActionListener<DeleteResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteByQueryRequestBuilder.doExecute(ActionListener<DeleteByQueryResponse> listener) |
protected void |
TransportDeleteByQueryAction.doExecute(DeleteByQueryRequest request,
ActionListener<DeleteByQueryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExistsRequestBuilder.doExecute(ActionListener<ExistsResponse> listener) |
protected void |
TransportExistsAction.doExecute(ExistsRequest request,
ActionListener<ExistsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ExplainRequestBuilder.doExecute(ActionListener<ExplainResponse> listener) |
protected void |
TransportExplainAction.doExecute(ExplainRequest request,
ActionListener<ExplainResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetRequestBuilder.doExecute(ActionListener<GetResponse> listener) |
protected void |
MultiGetRequestBuilder.doExecute(ActionListener<MultiGetResponse> listener) |
protected void |
TransportMultiGetAction.doExecute(MultiGetRequest request,
ActionListener<MultiGetResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
IndexRequestBuilder.doExecute(ActionListener<IndexResponse> listener) |
protected void |
TransportIndexAction.doExecute(IndexRequest request,
ActionListener<IndexResponse> listener) |
protected boolean |
TransportIndexAction.resolveRequest(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request,
ActionListener<IndexResponse> indexResponseActionListener) |
Modifier and Type | Method and Description |
---|---|
protected void |
DeleteIndexedScriptRequestBuilder.doExecute(ActionListener<DeleteIndexedScriptResponse> listener) |
protected void |
TransportDeleteIndexedScriptAction.doExecute(DeleteIndexedScriptRequest request,
ActionListener<DeleteIndexedScriptResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GetIndexedScriptRequestBuilder.doExecute(ActionListener<GetIndexedScriptResponse> listener) |
void |
TransportGetIndexedScriptAction.doExecute(GetIndexedScriptRequest request,
ActionListener<GetIndexedScriptResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutIndexedScriptRequestBuilder.doExecute(ActionListener<PutIndexedScriptResponse> listener) |
protected void |
TransportPutIndexedScriptAction.doExecute(PutIndexedScriptRequest request,
ActionListener<PutIndexedScriptResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
MoreLikeThisRequestBuilder.doExecute(ActionListener<SearchResponse> listener) |
protected void |
TransportMoreLikeThisAction.doExecute(MoreLikeThisRequest request,
ActionListener<SearchResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
MultiPercolateRequestBuilder.doExecute(ActionListener<MultiPercolateResponse> listener) |
protected void |
PercolateRequestBuilder.doExecute(ActionListener<PercolateResponse> listener) |
protected void |
TransportMultiPercolateAction.doExecute(MultiPercolateRequest request,
ActionListener<MultiPercolateResponse> listener) |
protected void |
TransportPercolateAction.doExecute(PercolateRequest request,
ActionListener<PercolateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClearScrollRequestBuilder.doExecute(ActionListener<ClearScrollResponse> listener) |
protected void |
MultiSearchRequestBuilder.doExecute(ActionListener<MultiSearchResponse> listener) |
protected void |
SearchRequestBuilder.doExecute(ActionListener<SearchResponse> listener) |
protected void |
SearchScrollRequestBuilder.doExecute(ActionListener<SearchResponse> listener) |
protected void |
TransportClearScrollAction.doExecute(ClearScrollRequest request,
ActionListener<ClearScrollResponse> listener) |
protected void |
TransportMultiSearchAction.doExecute(MultiSearchRequest request,
ActionListener<MultiSearchResponse> listener) |
protected void |
TransportSearchAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchScrollAction.doExecute(SearchScrollRequest request,
ActionListener<SearchResponse> listener) |
Modifier and Type | Field and Description |
---|---|
protected ActionListener<SearchResponse> |
TransportSearchTypeAction.BaseAsyncAction.listener |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportSearchDfsQueryThenFetchAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchScanAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchCountAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchDfsQueryAndFetchAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchQueryAndFetchAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
protected void |
TransportSearchQueryThenFetchAction.doExecute(SearchRequest searchRequest,
ActionListener<SearchResponse> listener) |
void |
TransportSearchScrollQueryThenFetchAction.execute(SearchScrollRequest request,
ParsedScrollId scrollId,
ActionListener<SearchResponse> listener) |
void |
TransportSearchScrollQueryAndFetchAction.execute(SearchScrollRequest request,
ParsedScrollId scrollId,
ActionListener<SearchResponse> listener) |
void |
TransportSearchScrollScanAction.execute(SearchScrollRequest request,
ParsedScrollId scrollId,
ActionListener<SearchResponse> listener) |
Constructor and Description |
---|
BaseAsyncAction(SearchRequest request,
ActionListener<SearchResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
SuggestRequestBuilder.doExecute(ActionListener<SuggestResponse> listener) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractListenableActionFuture<T,L> |
class |
AdapterActionFuture<T,L> |
class |
DelegatingActionListener<Instigator extends ActionResponse,Delegated extends ActionResponse> |
class |
PlainActionFuture<T> |
class |
PlainListenableActionFuture<T> |
Modifier and Type | Method and Description |
---|---|
void |
AbstractListenableActionFuture.addListener(ActionListener<T> listener) |
protected abstract boolean |
ActionFilter.Simple.apply(String action,
ActionRequest request,
ActionListener listener)
Applies this filter and returns
true if the execution chain should proceed, or false
if it should be aborted since the filter already handled the request and called the given listener. |
void |
ActionFilter.apply(String action,
ActionRequest request,
ActionListener listener,
ActionFilterChain chain)
Enables filtering the execution of an action on the request side, either by sending a response through the
ActionListener or by continuing the execution through the given chain |
void |
ActionFilter.Simple.apply(String action,
ActionRequest request,
ActionListener listener,
ActionFilterChain chain) |
protected abstract boolean |
ActionFilter.Simple.apply(String action,
ActionResponse response,
ActionListener listener)
Applies this filter and returns
true if the execution chain should proceed, or false
if it should be aborted since the filter already handled the response by calling the given listener. |
void |
ActionFilter.apply(String action,
ActionResponse response,
ActionListener listener,
ActionFilterChain chain)
Enables filtering the execution of an action on the response side, either by sending a response through the
ActionListener or by continuing the execution through the given chain |
void |
ActionFilter.Simple.apply(String action,
ActionResponse response,
ActionListener listener,
ActionFilterChain chain) |
protected abstract void |
TransportAction.doExecute(Request request,
ActionListener<Response> listener) |
void |
TransportAction.execute(Request request,
ActionListener<Response> listener) |
void |
AbstractListenableActionFuture.internalAddListener(ActionListener<T> listener) |
void |
ActionFilterChain.proceed(String action,
ActionRequest request,
ActionListener listener)
Continue processing the request.
|
void |
ActionFilterChain.proceed(String action,
ActionResponse response,
ActionListener listener)
Continue processing the response.
|
Constructor and Description |
---|
DelegatingActionListener(ActionListener<Delegated> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportBroadcastOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
Constructor and Description |
---|
AsyncBroadcastAction(Request request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportMasterNodeOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
protected abstract void |
TransportMasterNodeOperationAction.masterOperation(Request request,
ClusterState state,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
TransportClusterInfoAction.doMasterOperation(Request request,
String[] concreteIndices,
ClusterState state,
ActionListener<Response> listener) |
protected void |
TransportClusterInfoAction.masterOperation(Request request,
ClusterState state,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportNodesOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportShardReplicationOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
protected void |
TransportIndexReplicationOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
protected void |
TransportIndicesReplicationOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
protected boolean |
TransportShardReplicationOperationAction.resolveRequest(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request,
ActionListener<Response> listener)
Resolves the request, by default doing nothing.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TransportSingleCustomOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportInstanceSingleOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
protected abstract boolean |
TransportInstanceSingleOperationAction.resolveRequest(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<Response> listener)
Resolves the request.
|
protected abstract void |
TransportInstanceSingleOperationAction.shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportShardSingleOperationAction.doExecute(Request request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
MultiTermVectorsRequestBuilder.doExecute(ActionListener<MultiTermVectorsResponse> listener) |
protected void |
TermVectorRequestBuilder.doExecute(ActionListener<TermVectorResponse> listener) |
protected void |
TransportMultiTermVectorsAction.doExecute(MultiTermVectorsRequest request,
ActionListener<MultiTermVectorsResponse> listener) |
protected void |
TransportSingleShardTermVectorAction.doExecute(TermVectorRequest request,
ActionListener<TermVectorResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
UpdateRequestBuilder.doExecute(ActionListener<UpdateResponse> listener) |
protected void |
TransportUpdateAction.doExecute(UpdateRequest request,
ActionListener<UpdateResponse> listener) |
protected boolean |
TransportUpdateAction.resolveRequest(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener) |
protected void |
TransportUpdateAction.shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener) |
protected void |
TransportUpdateAction.shardOperation(TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener,
int retryCount) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesAdminClient.aliases(IndicesAliasesRequest request,
ActionListener<IndicesAliasesResponse> listener)
Allows to add/remove aliases from indices.
|
void |
IndicesAdminClient.aliasesExist(GetAliasesRequest request,
ActionListener<AliasesExistResponse> listener)
Check the existence of specified index aliases.
|
void |
IndicesAdminClient.analyze(AnalyzeRequest request,
ActionListener<AnalyzeResponse> listener)
Analyze text under the provided index.
|
void |
Client.bulk(BulkRequest request,
ActionListener<BulkResponse> listener)
Executes a bulk of index / delete operations.
|
void |
IndicesAdminClient.clearCache(ClearIndicesCacheRequest request,
ActionListener<ClearIndicesCacheResponse> listener)
Clear indices cache.
|
void |
Client.clearScroll(ClearScrollRequest request,
ActionListener<ClearScrollResponse> listener)
Clears the search contexts associated with specified scroll ids.
|
void |
IndicesAdminClient.close(CloseIndexRequest request,
ActionListener<CloseIndexResponse> listener)
Closes an index based on the index name.
|
void |
ClusterAdminClient.clusterStats(ClusterStatsRequest request,
ActionListener<ClusterStatsResponse> listener)
Cluster wide aggregated stats
|
void |
Client.count(CountRequest request,
ActionListener<CountResponse> listener)
A count of all the documents matching a specific query.
|
void |
IndicesAdminClient.create(CreateIndexRequest request,
ActionListener<CreateIndexResponse> listener)
Creates an index using an explicit request allowing to specify the settings of the index.
|
void |
ClusterAdminClient.createSnapshot(CreateSnapshotRequest request,
ActionListener<CreateSnapshotResponse> listener)
Creates a new snapshot.
|
void |
IndicesAdminClient.delete(DeleteIndexRequest request,
ActionListener<DeleteIndexResponse> listener)
Deletes an index based on the index name.
|
void |
Client.delete(DeleteRequest request,
ActionListener<DeleteResponse> listener)
Deletes a document from the index based on the index, type and id.
|
void |
Client.deleteByQuery(DeleteByQueryRequest request,
ActionListener<DeleteByQueryResponse> listener)
Deletes all documents from one or more indices based on a query.
|
void |
Client.deleteIndexedScript(DeleteIndexedScriptRequest request,
ActionListener<DeleteIndexedScriptResponse> listener)
delete an indexed script
|
void |
IndicesAdminClient.deleteMapping(DeleteMappingRequest request,
ActionListener<DeleteMappingResponse> listener)
Deletes mapping definition for a type into one or more indices.
|
void |
ClusterAdminClient.deleteRepository(DeleteRepositoryRequest request,
ActionListener<DeleteRepositoryResponse> listener)
Unregisters a repository.
|
void |
ClusterAdminClient.deleteSnapshot(DeleteSnapshotRequest request,
ActionListener<DeleteSnapshotResponse> listener)
Delete snapshot.
|
void |
IndicesAdminClient.deleteTemplate(DeleteIndexTemplateRequest request,
ActionListener<DeleteIndexTemplateResponse> listener)
Deletes an index template.
|
void |
IndicesAdminClient.deleteWarmer(DeleteWarmerRequest request,
ActionListener<DeleteWarmerResponse> listener)
Deletes an index warmer.
|
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,Client>> |
ElasticsearchClient.execute(Action<Request,Response,RequestBuilder,Client> action,
Request request,
ActionListener<Response> listener)
Executes a generic action, denoted by an
Action . |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,Client>> |
FilterClient.execute(Action<Request,Response,RequestBuilder,Client> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,ClusterAdminClient>> |
FilterClient.ClusterAdmin.execute(Action<Request,Response,RequestBuilder,ClusterAdminClient> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,IndicesAdminClient>> |
FilterClient.IndicesAdmin.execute(Action<Request,Response,RequestBuilder,IndicesAdminClient> action,
Request request,
ActionListener<Response> listener) |
void |
Client.exists(ExistsRequest request,
ActionListener<ExistsResponse> listener)
Checks existence of any documents matching a specific query.
|
void |
IndicesAdminClient.exists(IndicesExistsRequest request,
ActionListener<IndicesExistsResponse> listener)
The status of one or more indices.
|
void |
Client.explain(ExplainRequest request,
ActionListener<ExplainResponse> listener)
Computes a score explanation for the specified request.
|
void |
IndicesAdminClient.flush(FlushRequest request,
ActionListener<FlushResponse> listener)
Explicitly flush one or more indices (releasing memory from the node).
|
void |
Client.get(GetRequest request,
ActionListener<GetResponse> listener)
Gets the document that was indexed from an index with a type and id.
|
void |
IndicesAdminClient.getAliases(GetAliasesRequest request,
ActionListener<GetAliasesResponse> listener)
Get specific index aliases that exists in particular indices and / or by name.
|
void |
IndicesAdminClient.getFieldMappings(GetFieldMappingsRequest request,
ActionListener<GetFieldMappingsResponse> listener)
Get the mappings of specific fields
|
void |
IndicesAdminClient.getIndex(GetIndexRequest request,
ActionListener<GetIndexResponse> listener)
Get index metadata for particular indices.
|
void |
Client.getIndexedScript(GetIndexedScriptRequest request,
ActionListener<GetIndexedScriptResponse> listener)
Get an indexed script
|
void |
IndicesAdminClient.getMappings(GetMappingsRequest request,
ActionListener<GetMappingsResponse> listener)
Get the complete mappings of one or more types
|
void |
ClusterAdminClient.getRepositories(GetRepositoriesRequest request,
ActionListener<GetRepositoriesResponse> listener)
Gets repositories.
|
void |
IndicesAdminClient.getSettings(GetSettingsRequest request,
ActionListener<GetSettingsResponse> listener)
Executed a per index settings get request and returns the settings for the indices specified.
|
void |
ClusterAdminClient.getSnapshots(GetSnapshotsRequest request,
ActionListener<GetSnapshotsResponse> listener)
Get snapshot.
|
void |
IndicesAdminClient.getTemplates(GetIndexTemplatesRequest request,
ActionListener<GetIndexTemplatesResponse> listener)
Gets an index template.
|
void |
IndicesAdminClient.getWarmers(GetWarmersRequest request,
ActionListener<GetWarmersResponse> listener)
Returns a map of index warmers for the given get request.
|
void |
ClusterAdminClient.health(ClusterHealthRequest request,
ActionListener<ClusterHealthResponse> listener)
The health of the cluster.
|
void |
Client.index(IndexRequest request,
ActionListener<IndexResponse> listener)
Index a document associated with a given index and type.
|
void |
Client.moreLikeThis(MoreLikeThisRequest request,
ActionListener<SearchResponse> listener)
A more like this action to search for documents that are "like" a specific document.
|
void |
Client.multiGet(MultiGetRequest request,
ActionListener<MultiGetResponse> listener)
Multi get documents.
|
void |
Client.multiPercolate(MultiPercolateRequest request,
ActionListener<MultiPercolateResponse> listener)
Performs multiple percolate requests.
|
void |
Client.multiSearch(MultiSearchRequest request,
ActionListener<MultiSearchResponse> listener)
Performs multiple search requests.
|
void |
Client.multiTermVectors(MultiTermVectorsRequest request,
ActionListener<MultiTermVectorsResponse> listener)
Multi get term vectors.
|
void |
ClusterAdminClient.nodesHotThreads(NodesHotThreadsRequest request,
ActionListener<NodesHotThreadsResponse> listener)
Returns top N hot-threads samples per node.
|
void |
ClusterAdminClient.nodesInfo(NodesInfoRequest request,
ActionListener<NodesInfoResponse> listener)
Nodes info of the cluster.
|
void |
ClusterAdminClient.nodesRestart(NodesRestartRequest request,
ActionListener<NodesRestartResponse> listener)
Restarts nodes in the cluster.
|
void |
ClusterAdminClient.nodesShutdown(NodesShutdownRequest request,
ActionListener<NodesShutdownResponse> listener)
Shutdown nodes in the cluster.
|
void |
ClusterAdminClient.nodesStats(NodesStatsRequest request,
ActionListener<NodesStatsResponse> listener)
Nodes stats of the cluster.
|
void |
IndicesAdminClient.open(OpenIndexRequest request,
ActionListener<OpenIndexResponse> listener)
Open an index based on the index name.
|
void |
IndicesAdminClient.optimize(OptimizeRequest request,
ActionListener<OptimizeResponse> listener)
Explicitly optimize one or more indices into a the number of segments.
|
void |
ClusterAdminClient.pendingClusterTasks(PendingClusterTasksRequest request,
ActionListener<PendingClusterTasksResponse> listener)
Returns a list of the pending cluster tasks, that are scheduled to be executed.
|
void |
Client.percolate(PercolateRequest request,
ActionListener<PercolateResponse> listener)
Percolates a request returning the matches documents.
|
void |
Client.putIndexedScript(PutIndexedScriptRequest request,
ActionListener<PutIndexedScriptResponse> listener)
Put an indexed script
|
void |
IndicesAdminClient.putMapping(PutMappingRequest request,
ActionListener<PutMappingResponse> listener)
Add mapping definition for a type into one or more indices.
|
void |
ClusterAdminClient.putRepository(PutRepositoryRequest request,
ActionListener<PutRepositoryResponse> listener)
Registers a snapshot repository.
|
void |
IndicesAdminClient.putTemplate(PutIndexTemplateRequest request,
ActionListener<PutIndexTemplateResponse> listener)
Puts an index template.
|
void |
IndicesAdminClient.putWarmer(PutWarmerRequest request,
ActionListener<PutWarmerResponse> listener)
Puts an index search warmer to be applies when applicable.
|
void |
IndicesAdminClient.recoveries(RecoveryRequest request,
ActionListener<RecoveryResponse> listener)
Indices recoveries
|
void |
IndicesAdminClient.refresh(RefreshRequest request,
ActionListener<RefreshResponse> listener)
Explicitly refresh one or more indices (making the content indexed since the last refresh searchable).
|
void |
ClusterAdminClient.reroute(ClusterRerouteRequest request,
ActionListener<ClusterRerouteResponse> listener)
Reroutes allocation of shards.
|
void |
ClusterAdminClient.restoreSnapshot(RestoreSnapshotRequest request,
ActionListener<RestoreSnapshotResponse> listener)
Restores a snapshot.
|
void |
Client.search(SearchRequest request,
ActionListener<SearchResponse> listener)
Search across one or more indices and one or more types with a query.
|
void |
Client.searchScroll(SearchScrollRequest request,
ActionListener<SearchResponse> listener)
A search scroll request to continue searching a previous scrollable search request.
|
void |
ClusterAdminClient.searchShards(ClusterSearchShardsRequest request,
ActionListener<ClusterSearchShardsResponse> listener)
Returns list of shards the given search would be executed on.
|
void |
IndicesAdminClient.segments(IndicesSegmentsRequest request,
ActionListener<IndicesSegmentResponse> listener)
The segments of one or more indices.
|
void |
ClusterAdminClient.snapshotsStatus(SnapshotsStatusRequest request,
ActionListener<SnapshotsStatusResponse> listener)
Get snapshot status.
|
void |
ClusterAdminClient.state(ClusterStateRequest request,
ActionListener<ClusterStateResponse> listener)
The state of the cluster.
|
void |
IndicesAdminClient.stats(IndicesStatsRequest request,
ActionListener<IndicesStatsResponse> listener)
Indices stats.
|
void |
IndicesAdminClient.status(IndicesStatusRequest request,
ActionListener<IndicesStatusResponse> listener)
Deprecated.
|
void |
Client.suggest(SuggestRequest request,
ActionListener<SuggestResponse> listener)
Suggestions matching a specific phrase.
|
void |
Client.termVector(TermVectorRequest request,
ActionListener<TermVectorResponse> listener)
An action that returns the term vectors for a specific document.
|
void |
IndicesAdminClient.typesExists(TypesExistsRequest request,
ActionListener<TypesExistsResponse> listener)
Types exists
|
void |
Client.update(UpdateRequest request,
ActionListener<UpdateResponse> listener)
Updates a document based on a script.
|
void |
ClusterAdminClient.updateSettings(ClusterUpdateSettingsRequest request,
ActionListener<ClusterUpdateSettingsResponse> listener)
Update settings in the cluster.
|
void |
IndicesAdminClient.updateSettings(UpdateSettingsRequest request,
ActionListener<UpdateSettingsResponse> listener)
Updates settings of one or more indices.
|
void |
IndicesAdminClient.validateQuery(ValidateQueryRequest request,
ActionListener<ValidateQueryResponse> listener)
Validate a query for correctness.
|
void |
ClusterAdminClient.verifyRepository(VerifyRepositoryRequest request,
ActionListener<VerifyRepositoryResponse> listener)
Verifies a repository.
|
Modifier and Type | Method and Description |
---|---|
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,Client>> |
NodeClient.execute(Action<Request,Response,RequestBuilder,Client> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,ClusterAdminClient>> |
NodeClusterAdminClient.execute(Action<Request,Response,RequestBuilder,ClusterAdminClient> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,IndicesAdminClient>> |
NodeIndicesAdminClient.execute(Action<Request,Response,RequestBuilder,IndicesAdminClient> action,
Request request,
ActionListener<Response> listener) |
Modifier and Type | Class and Description |
---|---|
static class |
TransportClientNodesService.RetryListener<Response> |
Modifier and Type | Method and Description |
---|---|
void |
TransportClient.bulk(BulkRequest request,
ActionListener<BulkResponse> listener) |
void |
TransportClient.count(CountRequest request,
ActionListener<CountResponse> listener) |
void |
TransportClient.delete(DeleteRequest request,
ActionListener<DeleteResponse> listener) |
void |
TransportClient.deleteByQuery(DeleteByQueryRequest request,
ActionListener<DeleteByQueryResponse> listener) |
void |
TransportClientNodesService.NodeListenerCallback.doWithNode(DiscoveryNode node,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,Client>> |
TransportClient.execute(Action<Request,Response,RequestBuilder,Client> action,
Request request,
ActionListener<Response> listener) |
<Response> void |
TransportClientNodesService.execute(TransportClientNodesService.NodeListenerCallback<Response> callback,
ActionListener<Response> listener) |
void |
TransportClient.explain(ExplainRequest request,
ActionListener<ExplainResponse> listener) |
void |
TransportClient.get(GetRequest request,
ActionListener<GetResponse> listener) |
void |
TransportClient.index(IndexRequest request,
ActionListener<IndexResponse> listener) |
void |
TransportClient.moreLikeThis(MoreLikeThisRequest request,
ActionListener<SearchResponse> listener) |
void |
TransportClient.multiGet(MultiGetRequest request,
ActionListener<MultiGetResponse> listener) |
void |
TransportClient.multiSearch(MultiSearchRequest request,
ActionListener<MultiSearchResponse> listener) |
void |
TransportClient.multiTermVectors(MultiTermVectorsRequest request,
ActionListener<MultiTermVectorsResponse> listener) |
void |
TransportClient.percolate(PercolateRequest request,
ActionListener<PercolateResponse> listener) |
void |
TransportClient.search(SearchRequest request,
ActionListener<SearchResponse> listener) |
void |
TransportClient.searchScroll(SearchScrollRequest request,
ActionListener<SearchResponse> listener) |
void |
TransportClient.suggest(SuggestRequest request,
ActionListener<SuggestResponse> listener) |
void |
TransportClient.termVector(TermVectorRequest request,
ActionListener<TermVectorResponse> listener) |
void |
TransportClient.update(UpdateRequest request,
ActionListener<UpdateResponse> listener) |
Constructor and Description |
---|
RetryListener(TransportClientNodesService.NodeListenerCallback<Response> callback,
ActionListener<Response> listener,
com.google.common.collect.ImmutableList<DiscoveryNode> nodes,
int index,
ThreadPool threadPool,
ESLogger logger) |
Modifier and Type | Method and Description |
---|---|
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,Client>> |
InternalTransportClient.execute(Action<Request,Response,RequestBuilder,Client> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,ClusterAdminClient>> |
InternalTransportClusterAdminClient.execute(Action<Request,Response,RequestBuilder,ClusterAdminClient> action,
Request request,
ActionListener<Response> listener) |
<Request extends ActionRequest,Response extends ActionResponse,RequestBuilder extends ActionRequestBuilder<Request,Response,RequestBuilder,IndicesAdminClient>> |
InternalTransportIndicesAdminClient.execute(Action<Request,Response,RequestBuilder,IndicesAdminClient> action,
Request request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected CountDownLatch |
InternalClusterInfoService.updateIndicesStats(ActionListener<IndicesStatsResponse> listener)
Retrieve the latest indices stats, calling the listener when complete
|
protected CountDownLatch |
InternalClusterInfoService.updateNodeStats(ActionListener<NodesStatsResponse> listener)
Retrieve the latest nodes stats, calling the listener when complete
|
Constructor and Description |
---|
AckedClusterStateUpdateTask(AckedRequest request,
ActionListener<Response> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
MappingUpdatedAction.masterOperation(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state,
ActionListener<MappingUpdatedAction.MappingUpdatedResponse> listener) |
Modifier and Type | Method and Description |
---|---|
void |
VerifyNodeRepositoryAction.finishVerification(ActionListener<RepositoriesService.VerifyResponse> listener,
List<DiscoveryNode> nodes,
CopyOnWriteArrayList<VerificationFailure> errors) |
void |
RepositoriesService.registerRepository(RepositoriesService.RegisterRepositoryRequest request,
ActionListener<ClusterStateUpdateResponse> listener)
Registers new repository in the cluster
This method can be only called on the master node.
|
void |
RepositoriesService.unregisterRepository(RepositoriesService.UnregisterRepositoryRequest request,
ActionListener<ClusterStateUpdateResponse> listener)
Unregisters repository in the cluster
This method can be only called on the master node.
|
void |
VerifyNodeRepositoryAction.verify(String repository,
String verificationToken,
ActionListener<RepositoriesService.VerifyResponse> listener) |
void |
RepositoriesService.verifyRepository(String repositoryName,
ActionListener<RepositoriesService.VerifyResponse> listener) |
Modifier and Type | Class and Description |
---|---|
class |
AcknowledgedRestListener<T extends AcknowledgedResponse> |
class |
RestActionListener<Response>
An action listener that requires
RestActionListener.processResponse(Object) to be implemented
and will automatically handle failures. |
class |
RestBuilderListener<Response>
A REST action listener that builds an
XContentBuilder based response. |
class |
RestResponseListener<Response>
A REST enabled action listener that has a basic onFailure implementation, and requires
sub classes to only implement
RestResponseListener.buildResponse(Object) . |
class |
RestStatusToXContentListener<Response extends StatusToXContent> |
class |
RestToXContentListener<Response extends ToXContent>
A REST based action listener that assumes the response is of type
ToXContent and automatically
builds an XContent based response (wrapping the toXContent in startObject/endObject). |
Modifier and Type | Method and Description |
---|---|
void |
ScriptService.deleteScriptFromIndex(DeleteIndexedScriptRequest request,
ActionListener<DeleteResponse> listener) |
void |
ScriptService.putScriptToIndex(PutIndexedScriptRequest request,
ActionListener<IndexResponse> listener) |
void |
ScriptService.queryScriptIndex(GetIndexedScriptRequest request,
ActionListener<GetResponse> listener) |
Modifier and Type | Method and Description |
---|---|
void |
SearchServiceTransportAction.sendClearAllScrollContexts(DiscoveryNode node,
ClearScrollRequest request,
ActionListener<Boolean> actionListener) |
void |
SearchServiceTransportAction.sendFreeContext(DiscoveryNode node,
long contextId,
ClearScrollRequest request,
ActionListener<Boolean> actionListener) |
Modifier and Type | Method and Description |
---|---|
void |
RestoreService.addListener(ActionListener<RestoreService.RestoreCompletionResponse> listener)
Adds restore completion listener
This listener is called for each snapshot that finishes restore operation in the cluster.
|
void |
RestoreService.removeListener(ActionListener<RestoreService.RestoreCompletionResponse> listener)
Removes restore completion listener
This listener is called for each snapshot that finishes restore operation in the cluster.
|
void |
RestoreService.restoreSnapshot(RestoreService.RestoreRequest request,
ActionListener<RestoreInfo> listener)
Restores snapshot specified in the restore request.
|
Copyright © 2009–2015. All rights reserved.