Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClusterHealthAction.checkBlock(ClusterHealthRequest request,
ClusterState state) |
protected void |
TransportClusterHealthAction.masterOperation(ClusterHealthRequest request,
ClusterState unusedState,
ActionListener<ClusterHealthResponse> listener) |
Constructor and Description |
---|
ClusterHealthResponse(String clusterName,
String[] concreteIndices,
ClusterState clusterState)
needed for plugins BWC
|
ClusterHealthResponse(String clusterName,
String[] concreteIndices,
ClusterState clusterState,
int numberOfPendingTasks) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportNodesShutdownAction.checkBlock(NodesShutdownRequest request,
ClusterState state) |
protected void |
TransportNodesShutdownAction.masterOperation(NodesShutdownRequest request,
ClusterState state,
ActionListener<NodesShutdownResponse> listener) |
protected void |
TransportNodesShutdownAction.processBeforeDelegationToMaster(NodesShutdownRequest request,
ClusterState state) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteRepositoryAction.checkBlock(DeleteRepositoryRequest request,
ClusterState state) |
protected void |
TransportDeleteRepositoryAction.masterOperation(DeleteRepositoryRequest request,
ClusterState state,
ActionListener<DeleteRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetRepositoriesAction.checkBlock(GetRepositoriesRequest request,
ClusterState state) |
protected void |
TransportGetRepositoriesAction.masterOperation(GetRepositoriesRequest request,
ClusterState state,
ActionListener<GetRepositoriesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPutRepositoryAction.checkBlock(PutRepositoryRequest request,
ClusterState state) |
protected void |
TransportPutRepositoryAction.masterOperation(PutRepositoryRequest request,
ClusterState state,
ActionListener<PutRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportVerifyRepositoryAction.checkBlock(VerifyRepositoryRequest request,
ClusterState state) |
protected void |
TransportVerifyRepositoryAction.masterOperation(VerifyRepositoryRequest request,
ClusterState state,
ActionListener<VerifyRepositoryResponse> listener) |
Modifier and Type | Method and Description |
---|---|
ClusterState |
ClusterRerouteResponse.getState()
Returns the cluster state resulted from the cluster reroute request execution
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClusterRerouteAction.checkBlock(ClusterRerouteRequest request,
ClusterState state) |
protected void |
TransportClusterRerouteAction.masterOperation(ClusterRerouteRequest request,
ClusterState state,
ActionListener<ClusterRerouteResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClusterUpdateSettingsAction.checkBlock(ClusterUpdateSettingsRequest request,
ClusterState state) |
protected void |
TransportClusterUpdateSettingsAction.masterOperation(ClusterUpdateSettingsRequest request,
ClusterState state,
ActionListener<ClusterUpdateSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClusterSearchShardsAction.checkBlock(ClusterSearchShardsRequest request,
ClusterState state) |
protected void |
TransportClusterSearchShardsAction.masterOperation(ClusterSearchShardsRequest request,
ClusterState state,
ActionListener<ClusterSearchShardsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportCreateSnapshotAction.checkBlock(CreateSnapshotRequest request,
ClusterState state) |
protected void |
TransportCreateSnapshotAction.masterOperation(CreateSnapshotRequest request,
ClusterState state,
ActionListener<CreateSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteSnapshotAction.checkBlock(DeleteSnapshotRequest request,
ClusterState state) |
protected void |
TransportDeleteSnapshotAction.masterOperation(DeleteSnapshotRequest request,
ClusterState state,
ActionListener<DeleteSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetSnapshotsAction.checkBlock(GetSnapshotsRequest request,
ClusterState state) |
protected void |
TransportGetSnapshotsAction.masterOperation(GetSnapshotsRequest request,
ClusterState state,
ActionListener<GetSnapshotsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportRestoreSnapshotAction.checkBlock(RestoreSnapshotRequest request,
ClusterState state) |
protected void |
TransportRestoreSnapshotAction.masterOperation(RestoreSnapshotRequest request,
ClusterState state,
ActionListener<RestoreSnapshotResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportSnapshotsStatusAction.checkBlock(SnapshotsStatusRequest request,
ClusterState state) |
protected void |
TransportSnapshotsStatusAction.masterOperation(SnapshotsStatusRequest request,
ClusterState state,
ActionListener<SnapshotsStatusResponse> listener) |
Modifier and Type | Method and Description |
---|---|
ClusterState |
ClusterStateResponse.getState() |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClusterStateAction.checkBlock(ClusterStateRequest request,
ClusterState state) |
protected void |
TransportClusterStateAction.masterOperation(ClusterStateRequest request,
ClusterState state,
ActionListener<ClusterStateResponse> listener) |
Constructor and Description |
---|
ClusterStateResponse(ClusterName clusterName,
ClusterState clusterState) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPendingClusterTasksAction.checkBlock(PendingClusterTasksRequest request,
ClusterState state) |
protected void |
TransportPendingClusterTasksAction.masterOperation(PendingClusterTasksRequest request,
ClusterState state,
ActionListener<PendingClusterTasksResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportIndicesAliasesAction.checkBlock(IndicesAliasesRequest request,
ClusterState state) |
protected void |
TransportIndicesAliasesAction.masterOperation(IndicesAliasesRequest request,
ClusterState state,
ActionListener<IndicesAliasesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportAliasesExistAction.checkBlock(GetAliasesRequest request,
ClusterState state) |
protected void |
TransportAliasesExistAction.masterOperation(GetAliasesRequest request,
ClusterState state,
ActionListener<AliasesExistResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetAliasesAction.checkBlock(GetAliasesRequest request,
ClusterState state) |
protected void |
TransportGetAliasesAction.masterOperation(GetAliasesRequest request,
ClusterState state,
ActionListener<GetAliasesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportAnalyzeAction.checkRequestBlock(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request) |
protected ShardsIterator |
TransportAnalyzeAction.shards(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportClearIndicesCacheAction.checkGlobalBlock(ClusterState state,
ClearIndicesCacheRequest request) |
protected ClusterBlockException |
TransportClearIndicesCacheAction.checkRequestBlock(ClusterState state,
ClearIndicesCacheRequest request,
String[] concreteIndices) |
protected ClearIndicesCacheResponse |
TransportClearIndicesCacheAction.newResponse(ClearIndicesCacheRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportClearIndicesCacheAction.shards(ClusterState clusterState,
ClearIndicesCacheRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportCloseIndexAction.checkBlock(CloseIndexRequest request,
ClusterState state) |
protected void |
TransportCloseIndexAction.masterOperation(CloseIndexRequest request,
ClusterState state,
ActionListener<CloseIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportCreateIndexAction.checkBlock(CreateIndexRequest request,
ClusterState state) |
protected void |
TransportCreateIndexAction.masterOperation(CreateIndexRequest request,
ClusterState state,
ActionListener<CreateIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteIndexAction.checkBlock(DeleteIndexRequest request,
ClusterState state) |
protected void |
TransportDeleteIndexAction.masterOperation(DeleteIndexRequest request,
ClusterState state,
ActionListener<DeleteIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportIndicesExistsAction.checkBlock(IndicesExistsRequest request,
ClusterState state) |
protected void |
TransportIndicesExistsAction.masterOperation(IndicesExistsRequest request,
ClusterState state,
ActionListener<IndicesExistsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportTypesExistsAction.checkBlock(TypesExistsRequest request,
ClusterState state) |
protected void |
TransportTypesExistsAction.masterOperation(TypesExistsRequest request,
ClusterState state,
ActionListener<TypesExistsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportFlushAction.checkGlobalBlock(ClusterState state,
FlushRequest request) |
protected ClusterBlockException |
TransportFlushAction.checkRequestBlock(ClusterState state,
FlushRequest countRequest,
String[] concreteIndices) |
protected FlushResponse |
TransportFlushAction.newResponse(FlushRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportFlushAction.shards(ClusterState clusterState,
FlushRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetIndexAction.checkBlock(GetIndexRequest request,
ClusterState state) |
protected void |
TransportGetIndexAction.doMasterOperation(GetIndexRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteMappingAction.checkBlock(DeleteMappingRequest request,
ClusterState state) |
protected void |
TransportDeleteMappingAction.masterOperation(DeleteMappingRequest request,
ClusterState state,
ActionListener<DeleteMappingResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetMappingsAction.checkBlock(GetMappingsRequest request,
ClusterState state) |
protected void |
TransportGetMappingsAction.doMasterOperation(GetMappingsRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetMappingsResponse> listener) |
protected ShardsIterator |
TransportGetFieldMappingsIndexAction.shards(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPutMappingAction.checkBlock(PutMappingRequest request,
ClusterState state) |
protected void |
TransportPutMappingAction.masterOperation(PutMappingRequest request,
ClusterState state,
ActionListener<PutMappingResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportOpenIndexAction.checkBlock(OpenIndexRequest request,
ClusterState state) |
protected void |
TransportOpenIndexAction.masterOperation(OpenIndexRequest request,
ClusterState state,
ActionListener<OpenIndexResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportOptimizeAction.checkGlobalBlock(ClusterState state,
OptimizeRequest request) |
protected ClusterBlockException |
TransportOptimizeAction.checkRequestBlock(ClusterState state,
OptimizeRequest request,
String[] concreteIndices) |
protected OptimizeResponse |
TransportOptimizeAction.newResponse(OptimizeRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportOptimizeAction.shards(ClusterState clusterState,
OptimizeRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportRecoveryAction.checkGlobalBlock(ClusterState state,
RecoveryRequest request) |
protected ClusterBlockException |
TransportRecoveryAction.checkRequestBlock(ClusterState state,
RecoveryRequest request,
String[] concreteIndices) |
protected RecoveryResponse |
TransportRecoveryAction.newResponse(RecoveryRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportRecoveryAction.shards(ClusterState state,
RecoveryRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportRefreshAction.checkGlobalBlock(ClusterState state,
RefreshRequest request) |
protected ClusterBlockException |
TransportRefreshAction.checkRequestBlock(ClusterState state,
RefreshRequest countRequest,
String[] concreteIndices) |
protected RefreshResponse |
TransportRefreshAction.newResponse(RefreshRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportRefreshAction.shards(ClusterState clusterState,
RefreshRequest request,
String[] concreteIndices)
The refresh request works against *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportIndicesSegmentsAction.checkGlobalBlock(ClusterState state,
IndicesSegmentsRequest request) |
protected ClusterBlockException |
TransportIndicesSegmentsAction.checkRequestBlock(ClusterState state,
IndicesSegmentsRequest countRequest,
String[] concreteIndices) |
protected IndicesSegmentResponse |
TransportIndicesSegmentsAction.newResponse(IndicesSegmentsRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportIndicesSegmentsAction.shards(ClusterState clusterState,
IndicesSegmentsRequest request,
String[] concreteIndices)
Segments goes across *all* active shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetSettingsAction.checkBlock(GetSettingsRequest request,
ClusterState state) |
protected void |
TransportGetSettingsAction.masterOperation(GetSettingsRequest request,
ClusterState state,
ActionListener<GetSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportUpdateSettingsAction.checkBlock(UpdateSettingsRequest request,
ClusterState state) |
protected void |
TransportUpdateSettingsAction.masterOperation(UpdateSettingsRequest request,
ClusterState state,
ActionListener<UpdateSettingsResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportIndicesStatsAction.checkGlobalBlock(ClusterState state,
IndicesStatsRequest request) |
protected ClusterBlockException |
TransportIndicesStatsAction.checkRequestBlock(ClusterState state,
IndicesStatsRequest request,
String[] concreteIndices) |
protected IndicesStatsResponse |
TransportIndicesStatsAction.newResponse(IndicesStatsRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportIndicesStatsAction.shards(ClusterState clusterState,
IndicesStatsRequest request,
String[] concreteIndices)
Status goes across *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportIndicesStatusAction.checkGlobalBlock(ClusterState state,
IndicesStatusRequest request)
Deprecated.
|
protected ClusterBlockException |
TransportIndicesStatusAction.checkRequestBlock(ClusterState state,
IndicesStatusRequest countRequest,
String[] concreteIndices)
Deprecated.
|
protected IndicesStatusResponse |
TransportIndicesStatusAction.newResponse(IndicesStatusRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState)
Deprecated.
|
protected GroupShardsIterator |
TransportIndicesStatusAction.shards(ClusterState state,
IndicesStatusRequest request,
String[] concreteIndices)
Deprecated.
Status goes across *all* shards.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteIndexTemplateAction.checkBlock(DeleteIndexTemplateRequest request,
ClusterState state) |
protected void |
TransportDeleteIndexTemplateAction.masterOperation(DeleteIndexTemplateRequest request,
ClusterState state,
ActionListener<DeleteIndexTemplateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetIndexTemplatesAction.checkBlock(GetIndexTemplatesRequest request,
ClusterState state) |
protected void |
TransportGetIndexTemplatesAction.masterOperation(GetIndexTemplatesRequest request,
ClusterState state,
ActionListener<GetIndexTemplatesResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPutIndexTemplateAction.checkBlock(PutIndexTemplateRequest request,
ClusterState state) |
protected void |
TransportPutIndexTemplateAction.masterOperation(PutIndexTemplateRequest request,
ClusterState state,
ActionListener<PutIndexTemplateResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportValidateQueryAction.checkGlobalBlock(ClusterState state,
ValidateQueryRequest request) |
protected ClusterBlockException |
TransportValidateQueryAction.checkRequestBlock(ClusterState state,
ValidateQueryRequest countRequest,
String[] concreteIndices) |
protected ValidateQueryResponse |
TransportValidateQueryAction.newResponse(ValidateQueryRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportValidateQueryAction.shards(ClusterState clusterState,
ValidateQueryRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteWarmerAction.checkBlock(DeleteWarmerRequest request,
ClusterState state) |
protected void |
TransportDeleteWarmerAction.masterOperation(DeleteWarmerRequest request,
ClusterState state,
ActionListener<DeleteWarmerResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportGetWarmersAction.checkBlock(GetWarmersRequest request,
ClusterState state) |
protected void |
TransportGetWarmersAction.doMasterOperation(GetWarmersRequest request,
String[] concreteIndices,
ClusterState state,
ActionListener<GetWarmersResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPutWarmerAction.checkBlock(PutWarmerRequest request,
ClusterState state) |
protected void |
TransportPutWarmerAction.masterOperation(PutWarmerRequest request,
ClusterState state,
ActionListener<PutWarmerResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected TransportShardReplicationOperationAction.PrimaryResponse<BulkShardResponse,BulkShardRequest> |
TransportShardBulkAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected ShardIterator |
TransportShardBulkAction.shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportCountAction.checkGlobalBlock(ClusterState state,
CountRequest request) |
protected ClusterBlockException |
TransportCountAction.checkRequestBlock(ClusterState state,
CountRequest countRequest,
String[] concreteIndices) |
protected CountResponse |
TransportCountAction.newResponse(CountRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportCountAction.shards(ClusterState clusterState,
CountRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportDeleteByQueryAction.checkGlobalBlock(ClusterState state,
DeleteByQueryRequest replicationPingRequest) |
protected ClusterBlockException |
TransportIndexDeleteByQueryAction.checkGlobalBlock(ClusterState state,
org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
protected ClusterBlockException |
TransportDeleteByQueryAction.checkRequestBlock(ClusterState state,
DeleteByQueryRequest request,
String[] concreteIndices) |
protected ClusterBlockException |
TransportIndexDeleteByQueryAction.checkRequestBlock(ClusterState state,
org.elasticsearch.action.deletebyquery.IndexDeleteByQueryRequest request) |
protected Map<String,Set<String>> |
TransportDeleteByQueryAction.resolveRouting(ClusterState clusterState,
DeleteByQueryRequest request) |
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteByQueryResponse,ShardDeleteByQueryRequest> |
TransportShardDeleteByQueryAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected ShardIterator |
TransportShardDeleteByQueryAction.shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportExistsAction.checkGlobalBlock(ClusterState state,
ExistsRequest request) |
protected ClusterBlockException |
TransportExistsAction.checkRequestBlock(ClusterState state,
ExistsRequest countRequest,
String[] concreteIndices) |
protected ExistsResponse |
TransportExistsAction.newResponse(ExistsRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportExistsAction.shards(ClusterState clusterState,
ExistsRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportExplainAction.resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected ShardIterator |
TransportExplainAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportGetAction.resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected void |
TransportShardMultiGetAction.resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected ShardIterator |
TransportGetAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected ShardIterator |
TransportShardMultiGetAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
TransportIndexAction.resolveRequest(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request,
ActionListener<IndexResponse> indexResponseActionListener) |
protected TransportShardReplicationOperationAction.PrimaryResponse<IndexResponse,IndexRequest> |
TransportIndexAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected ShardIterator |
TransportIndexAction.shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportPercolateAction.checkGlobalBlock(ClusterState state,
PercolateRequest request) |
protected ClusterBlockException |
TransportPercolateAction.checkRequestBlock(ClusterState state,
PercolateRequest request,
String[] concreteIndices) |
protected PercolateResponse |
TransportPercolateAction.newResponse(PercolateRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportPercolateAction.shards(ClusterState clusterState,
PercolateRequest request,
String[] concreteIndices) |
protected ShardIterator |
TransportShardMultiPercolateAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
Modifier and Type | Field and Description |
---|---|
protected ClusterState |
TransportSearchTypeAction.BaseAsyncAction.clusterState |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportSuggestAction.checkGlobalBlock(ClusterState state,
SuggestRequest request) |
protected ClusterBlockException |
TransportSuggestAction.checkRequestBlock(ClusterState state,
SuggestRequest countRequest,
String[] concreteIndices) |
protected SuggestResponse |
TransportSuggestAction.newResponse(SuggestRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected GroupShardsIterator |
TransportSuggestAction.shards(ClusterState clusterState,
SuggestRequest request,
String[] concreteIndices) |
Modifier and Type | Method and Description |
---|---|
boolean |
AutoCreateIndex.shouldAutoCreate(String index,
ClusterState state)
Should the index be auto created?
|
Modifier and Type | Method and Description |
---|---|
protected abstract ClusterBlockException |
TransportBroadcastOperationAction.checkGlobalBlock(ClusterState state,
Request request) |
protected abstract ClusterBlockException |
TransportBroadcastOperationAction.checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices) |
protected abstract Response |
TransportBroadcastOperationAction.newResponse(Request request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState) |
protected abstract GroupShardsIterator |
TransportBroadcastOperationAction.shards(ClusterState clusterState,
Request request,
String[] concreteIndices)
Determines the shards this operation will be executed on.
|
Modifier and Type | Method and Description |
---|---|
protected abstract ClusterBlockException |
TransportMasterNodeOperationAction.checkBlock(Request request,
ClusterState state) |
protected abstract void |
TransportMasterNodeOperationAction.masterOperation(Request request,
ClusterState state,
ActionListener<Response> listener) |
protected void |
TransportMasterNodeOperationAction.processBeforeDelegationToMaster(Request request,
ClusterState state) |
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 ClusterBlockException |
TransportShardReplicationOperationAction.checkGlobalBlock(ClusterState state) |
protected ClusterBlockException |
TransportIndexReplicationOperationAction.checkGlobalBlock(ClusterState state,
Request request) |
protected abstract ClusterBlockException |
TransportIndicesReplicationOperationAction.checkGlobalBlock(ClusterState state,
Request request) |
protected ClusterBlockException |
TransportIndexReplicationOperationAction.checkRequestBlock(ClusterState state,
Request request) |
protected abstract ClusterBlockException |
TransportIndicesReplicationOperationAction.checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices) |
protected ClusterBlockException |
TransportShardReplicationOperationAction.checkRequestBlock(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request) |
protected boolean |
TransportShardReplicationOperationAction.resolveRequest(ClusterState state,
TransportShardReplicationOperationAction.InternalRequest request,
ActionListener<Response> listener)
Resolves the request, by default doing nothing.
|
protected abstract Map<String,Set<String>> |
TransportIndicesReplicationOperationAction.resolveRouting(ClusterState clusterState,
Request request) |
protected abstract TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest> |
TransportShardReplicationOperationAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected abstract ShardIterator |
TransportShardReplicationOperationAction.shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportSingleCustomOperationAction.checkGlobalBlock(ClusterState state) |
protected ClusterBlockException |
TransportSingleCustomOperationAction.checkRequestBlock(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request) |
protected abstract ShardsIterator |
TransportSingleCustomOperationAction.shards(ClusterState state,
TransportSingleCustomOperationAction.InternalRequest request)
Can return null to execute on this local node.
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportInstanceSingleOperationAction.checkGlobalBlock(ClusterState state) |
protected ClusterBlockException |
TransportInstanceSingleOperationAction.checkRequestBlock(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request) |
protected abstract boolean |
TransportInstanceSingleOperationAction.resolveRequest(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<Response> listener)
Resolves the request.
|
protected abstract ShardIterator |
TransportInstanceSingleOperationAction.shards(ClusterState clusterState,
TransportInstanceSingleOperationAction.InternalRequest request)
Should return an iterator with a single shard!
|
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
TransportShardSingleOperationAction.checkGlobalBlock(ClusterState state) |
protected ClusterBlockException |
TransportShardSingleOperationAction.checkRequestBlock(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected void |
TransportShardSingleOperationAction.resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected abstract ShardIterator |
TransportShardSingleOperationAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
TransportSingleShardTermVectorAction.resolveRequest(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected ShardIterator |
TransportSingleShardMultiTermsVectorAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
protected ShardIterator |
TransportSingleShardTermVectorAction.shards(ClusterState state,
TransportShardSingleOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
TransportUpdateAction.resolveRequest(ClusterState state,
TransportInstanceSingleOperationAction.InternalRequest request,
ActionListener<UpdateResponse> listener) |
protected ShardIterator |
TransportUpdateAction.shards(ClusterState clusterState,
TransportInstanceSingleOperationAction.InternalRequest request) |
Modifier and Type | Method and Description |
---|---|
ClusterState |
ClusterState.Builder.build() |
abstract ClusterState |
ClusterStateUpdateTask.execute(ClusterState currentState)
Update the cluster state based on the current state.
|
static ClusterState |
ClusterState.Builder.fromBytes(byte[] data,
DiscoveryNode localNode,
ClusterName defaultClusterName) |
ClusterState |
ClusterStateObserver.observedState()
last cluster state observer by this observer.
|
ClusterState |
ClusterChangedEvent.previousState() |
static ClusterState |
ClusterState.Builder.readFrom(StreamInput in,
DiscoveryNode localNode,
ClusterName defaultClusterName) |
ClusterState |
ClusterState.settingsFilter(SettingsFilter settingsFilter) |
ClusterState |
ClusterService.state()
The current state.
|
ClusterState |
ClusterChangedEvent.state() |
ClusterState |
ClusterState.status(ClusterState.ClusterStateStatus newStatus) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterStateObserver.ChangePredicate.apply(ClusterState previousState,
ClusterState.ClusterStateStatus previousStatus,
ClusterState newState,
ClusterState.ClusterStateStatus newStatus)
a rough check used when starting to monitor for a new change.
|
boolean |
ClusterStateObserver.ValidationPredicate.apply(ClusterState previousState,
ClusterState.ClusterStateStatus previousStatus,
ClusterState newState,
ClusterState.ClusterStateStatus newStatus) |
boolean |
ClusterStateObserver.EventPredicate.apply(ClusterState previousState,
ClusterState.ClusterStateStatus previousStatus,
ClusterState newState,
ClusterState.ClusterStateStatus newStatus) |
static ClusterState.Builder |
ClusterState.builder(ClusterState state) |
void |
AckedClusterStateUpdateTask.clusterStateProcessed(String source,
ClusterState oldState,
ClusterState newState) |
abstract void |
ProcessedClusterStateUpdateTask.clusterStateProcessed(String source,
ClusterState oldState,
ClusterState newState)
Called when the result of the
ClusterStateUpdateTask.execute(ClusterState) have been processed
properly by all listeners. |
abstract ClusterState |
ClusterStateUpdateTask.execute(ClusterState currentState)
Update the cluster state based on the current state.
|
void |
ClusterStateObserver.Listener.onNewClusterState(ClusterState state)
called when a new state is observed
|
void |
ClusterStateObserver.reset(ClusterState toState)
reset this observer to the give cluster state.
|
static byte[] |
ClusterState.Builder.toBytes(ClusterState state) |
protected abstract boolean |
ClusterStateObserver.ValidationPredicate.validate(ClusterState newState) |
static void |
ClusterState.Builder.writeTo(ClusterState state,
StreamOutput out) |
Constructor and Description |
---|
Builder(ClusterState state) |
ClusterChangedEvent(String source,
ClusterState state,
ClusterState previousState) |
ClusterState(long version,
ClusterState state) |
Modifier and Type | Method and Description |
---|---|
protected ClusterBlockException |
MappingUpdatedAction.checkBlock(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state) |
protected void |
MappingUpdatedAction.masterOperation(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state,
ActionListener<MappingUpdatedAction.MappingUpdatedResponse> listener) |
void |
NodeIndexDeletedAction.nodeIndexDeleted(ClusterState clusterState,
String index,
Settings indexSettings,
String nodeId) |
void |
NodeMappingRefreshAction.nodeMappingRefresh(ClusterState state,
NodeMappingRefreshAction.NodeMappingRefreshRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
MetaDataCreateIndexService.validateIndexName(String index,
ClusterState state) |
Modifier and Type | Method and Description |
---|---|
RoutingNodes |
RoutingTable.routingNodes(ClusterState state) |
Constructor and Description |
---|
RoutingNodes(ClusterState clusterState) |
Modifier and Type | Method and Description |
---|---|
RoutingAllocation.Result |
AllocationService.applyFailedShard(ClusterState clusterState,
ShardRouting failedShard) |
RoutingAllocation.Result |
AllocationService.applyFailedShards(ClusterState clusterState,
List<ShardRouting> failedShards)
Applies the failed shards.
|
RoutingAllocation.Result |
AllocationService.applyStartedShards(ClusterState clusterState,
List<? extends ShardRouting> startedShards)
Applies the started shards.
|
RoutingAllocation.Result |
AllocationService.applyStartedShards(ClusterState clusterState,
List<? extends ShardRouting> startedShards,
boolean withReroute) |
RoutingAllocation.Result |
AllocationService.reroute(ClusterState clusterState)
Reroutes the routing table based on the live nodes.
|
RoutingAllocation.Result |
AllocationService.reroute(ClusterState clusterState,
AllocationCommands commands) |
RoutingAllocation.Result |
AllocationService.reroute(ClusterState clusterState,
AllocationCommands commands,
boolean explain) |
RoutingAllocation.Result |
AllocationService.reroute(ClusterState clusterState,
boolean debug)
Reroutes the routing table based on the live nodes.
|
RoutingAllocation.Result |
AllocationService.rerouteWithNoReassign(ClusterState clusterState)
Only handles reroute but *without* any reassignment of unassigned shards or rebalancing.
|
RoutingAllocation.Result |
AllocationService.rerouteWithNoReassign(ClusterState clusterState,
boolean debug)
Only handles reroute but *without* any reassignment of unassigned shards or rebalancing.
|
Modifier and Type | Method and Description |
---|---|
GroupShardsIterator |
OperationRouting.broadcastDeleteShards(ClusterState clusterState,
String index) |
GroupShardsIterator |
OperationRouting.deleteByQueryShards(ClusterState clusterState,
String index,
Set<String> routing) |
ShardIterator |
OperationRouting.deleteShards(ClusterState clusterState,
String index,
String type,
String id,
String routing) |
ShardIterator |
OperationRouting.getShards(ClusterState clusterState,
String index,
int shardId,
String preference) |
ShardIterator |
OperationRouting.getShards(ClusterState clusterState,
String index,
String type,
String id,
String routing,
String preference) |
ShardIterator |
OperationRouting.indexShards(ClusterState clusterState,
String index,
String type,
String id,
String routing) |
GroupShardsIterator |
OperationRouting.searchShards(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
int |
OperationRouting.searchShardsCount(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
Modifier and Type | Method and Description |
---|---|
GroupShardsIterator |
PlainOperationRouting.broadcastDeleteShards(ClusterState clusterState,
String index) |
GroupShardsIterator |
PlainOperationRouting.deleteByQueryShards(ClusterState clusterState,
String index,
Set<String> routing) |
ShardIterator |
PlainOperationRouting.deleteShards(ClusterState clusterState,
String index,
String type,
String id,
String routing) |
ShardIterator |
PlainOperationRouting.getShards(ClusterState clusterState,
String index,
int shardId,
String preference) |
ShardIterator |
PlainOperationRouting.getShards(ClusterState clusterState,
String index,
String type,
String id,
String routing,
String preference) |
IndexMetaData |
PlainOperationRouting.indexMetaData(ClusterState clusterState,
String index) |
protected IndexRoutingTable |
PlainOperationRouting.indexRoutingTable(ClusterState clusterState,
String index) |
ShardIterator |
PlainOperationRouting.indexShards(ClusterState clusterState,
String index,
String type,
String id,
String routing) |
GroupShardsIterator |
PlainOperationRouting.searchShards(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
int |
PlainOperationRouting.searchShardsCount(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
Map<String,Set<String>> routing,
String preference) |
protected IndexShardRoutingTable |
PlainOperationRouting.shards(ClusterState clusterState,
String index,
int shardId) |
protected IndexShardRoutingTable |
PlainOperationRouting.shards(ClusterState clusterState,
String index,
String type,
String id,
String routing) |
Modifier and Type | Method and Description |
---|---|
ClusterState |
InternalClusterService.state() |
Modifier and Type | Method and Description |
---|---|
void |
DiscoveryService.publish(ClusterState clusterState,
Discovery.AckListener ackListener)
Publish all the changes to the cluster from the master (can be called just by the master).
|
void |
Discovery.publish(ClusterState clusterState,
Discovery.AckListener ackListener)
Publish all the changes to the cluster from the master (can be called just by the master).
|
Modifier and Type | Method and Description |
---|---|
void |
LocalDiscovery.publish(ClusterState clusterState,
Discovery.AckListener ackListener) |
Modifier and Type | Method and Description |
---|---|
void |
ZenDiscovery.publish(ClusterState clusterState,
Discovery.AckListener ackListener)
end of
PingContextProvider implementation |
Modifier and Type | Method and Description |
---|---|
void |
NodesFaultDetection.updateNodesAndPing(ClusterState clusterState)
make sure that nodes in clusterState are pinged.
|
Modifier and Type | Method and Description |
---|---|
void |
PublishClusterStateAction.NewClusterStateListener.onNewClusterState(ClusterState clusterState,
PublishClusterStateAction.NewClusterStateListener.NewStateProcessed newStateProcessed) |
void |
PublishClusterStateAction.publish(ClusterState clusterState,
Discovery.AckListener ackListener) |
Modifier and Type | Method and Description |
---|---|
protected void |
GatewayService.checkStateMeetsSettingsAndMaybeRecover(ClusterState state,
boolean asyncRecovery) |
void |
Gateway.GatewayStateRecoveredListener.onSuccess(ClusterState recoveredState) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesService.deleteClosedIndex(String reason,
IndexMetaData metaData,
ClusterState clusterState) |
void |
IndicesService.deleteIndexStore(String reason,
IndexMetaData metaData,
ClusterState clusterState)
Deletes the index store trying to acquire all shards locks for this index.
|
Modifier and Type | Method and Description |
---|---|
ClusterState |
RiverClusterService.state()
The current state.
|
Modifier and Type | Method and Description |
---|---|
protected RiverClusterState |
RiversRouter.updateRiverClusterState(String source,
RiverClusterState currentState,
ClusterState newClusterState,
CountDown countDown) |
Modifier and Type | Method and Description |
---|---|
static boolean |
SnapshotsService.isRepositoryInUse(ClusterState clusterState,
String repository)
Checks if a repository is currently in use by one of the snapshots
|
static boolean |
RestoreService.isRepositoryInUse(ClusterState clusterState,
String repository)
Checks if a repository is currently in use by one of the snapshots
|
Copyright © 2009–2015. All rights reserved.