|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ClusterState in org.elasticsearch.action.admin.cluster.health |
---|
Methods in org.elasticsearch.action.admin.cluster.health with parameters of type ClusterState | |
---|---|
protected ClusterHealthResponse |
TransportClusterHealthAction.masterOperation(ClusterHealthRequest request,
ClusterState unusedState)
|
Uses of ClusterState in org.elasticsearch.action.admin.cluster.node.shutdown |
---|
Methods in org.elasticsearch.action.admin.cluster.node.shutdown with parameters of type ClusterState | |
---|---|
protected NodesShutdownResponse |
TransportNodesShutdownAction.masterOperation(NodesShutdownRequest request,
ClusterState state)
|
protected void |
TransportNodesShutdownAction.processBeforeDelegationToMaster(NodesShutdownRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.cluster.reroute |
---|
Methods in org.elasticsearch.action.admin.cluster.reroute with parameters of type ClusterState | |
---|---|
protected ClusterRerouteResponse |
TransportClusterRerouteAction.masterOperation(ClusterRerouteRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.cluster.settings |
---|
Methods in org.elasticsearch.action.admin.cluster.settings with parameters of type ClusterState | |
---|---|
protected ClusterUpdateSettingsResponse |
TransportClusterUpdateSettingsAction.masterOperation(ClusterUpdateSettingsRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.cluster.state |
---|
Methods in org.elasticsearch.action.admin.cluster.state that return ClusterState | |
---|---|
ClusterState |
ClusterStateResponse.getState()
|
ClusterState |
ClusterStateResponse.state()
|
Methods in org.elasticsearch.action.admin.cluster.state with parameters of type ClusterState | |
---|---|
protected ClusterStateResponse |
TransportClusterStateAction.masterOperation(ClusterStateRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.alias |
---|
Methods in org.elasticsearch.action.admin.indices.alias with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndicesAliasesAction.checkBlock(IndicesAliasesRequest request,
ClusterState state)
|
protected IndicesAliasesResponse |
TransportIndicesAliasesAction.masterOperation(IndicesAliasesRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.analyze |
---|
Methods in org.elasticsearch.action.admin.indices.analyze with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportAnalyzeAction.checkGlobalBlock(ClusterState state,
AnalyzeRequest request)
|
protected ClusterBlockException |
TransportAnalyzeAction.checkRequestBlock(ClusterState state,
AnalyzeRequest request)
|
protected ShardsIterator |
TransportAnalyzeAction.shards(ClusterState state,
AnalyzeRequest request)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.cache.clear |
---|
Methods in org.elasticsearch.action.admin.indices.cache.clear with parameters of type ClusterState | |
---|---|
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. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.close |
---|
Methods in org.elasticsearch.action.admin.indices.close with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportCloseIndexAction.checkBlock(CloseIndexRequest request,
ClusterState state)
|
protected CloseIndexResponse |
TransportCloseIndexAction.masterOperation(CloseIndexRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.create |
---|
Methods in org.elasticsearch.action.admin.indices.create with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportCreateIndexAction.checkBlock(CreateIndexRequest request,
ClusterState state)
|
protected CreateIndexResponse |
TransportCreateIndexAction.masterOperation(CreateIndexRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.delete |
---|
Methods in org.elasticsearch.action.admin.indices.delete with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportDeleteIndexAction.checkBlock(DeleteIndexRequest request,
ClusterState state)
|
protected DeleteIndexResponse |
TransportDeleteIndexAction.masterOperation(DeleteIndexRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.exists |
---|
Methods in org.elasticsearch.action.admin.indices.exists with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndicesExistsAction.checkBlock(IndicesExistsRequest request,
ClusterState state)
|
protected IndicesExistsResponse |
TransportIndicesExistsAction.masterOperation(IndicesExistsRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.flush |
---|
Methods in org.elasticsearch.action.admin.indices.flush with parameters of type ClusterState | |
---|---|
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. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.gateway.snapshot |
---|
Methods in org.elasticsearch.action.admin.indices.gateway.snapshot with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportGatewaySnapshotAction.checkGlobalBlock(ClusterState state,
GatewaySnapshotRequest request)
|
protected ClusterBlockException |
TransportGatewaySnapshotAction.checkRequestBlock(ClusterState state,
GatewaySnapshotRequest request,
String[] concreteIndices)
|
protected GatewaySnapshotResponse |
TransportGatewaySnapshotAction.newResponse(GatewaySnapshotRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState)
|
protected GroupShardsIterator |
TransportGatewaySnapshotAction.shards(ClusterState clusterState,
GatewaySnapshotRequest request,
String[] concreteIndices)
The snapshot request works against all primary shards. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.mapping.delete |
---|
Methods in org.elasticsearch.action.admin.indices.mapping.delete with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportDeleteMappingAction.checkBlock(DeleteMappingRequest request,
ClusterState state)
|
protected DeleteMappingResponse |
TransportDeleteMappingAction.masterOperation(DeleteMappingRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.mapping.put |
---|
Methods in org.elasticsearch.action.admin.indices.mapping.put with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportPutMappingAction.checkBlock(PutMappingRequest request,
ClusterState state)
|
protected PutMappingResponse |
TransportPutMappingAction.masterOperation(PutMappingRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.open |
---|
Methods in org.elasticsearch.action.admin.indices.open with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportOpenIndexAction.checkBlock(OpenIndexRequest request,
ClusterState state)
|
protected OpenIndexResponse |
TransportOpenIndexAction.masterOperation(OpenIndexRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.optimize |
---|
Methods in org.elasticsearch.action.admin.indices.optimize with parameters of type ClusterState | |
---|---|
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. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.refresh |
---|
Methods in org.elasticsearch.action.admin.indices.refresh with parameters of type ClusterState | |
---|---|
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. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.segments |
---|
Methods in org.elasticsearch.action.admin.indices.segments with parameters of type ClusterState | |
---|---|
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. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.settings |
---|
Methods in org.elasticsearch.action.admin.indices.settings with parameters of type ClusterState | |
---|---|
protected UpdateSettingsResponse |
TransportUpdateSettingsAction.masterOperation(UpdateSettingsRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.stats |
---|
Methods in org.elasticsearch.action.admin.indices.stats with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndicesStatsAction.checkGlobalBlock(ClusterState state,
IndicesStatsRequest request)
|
protected ClusterBlockException |
TransportIndicesStatsAction.checkRequestBlock(ClusterState state,
IndicesStatsRequest request,
String[] concreteIndices)
|
protected IndicesStats |
TransportIndicesStatsAction.newResponse(IndicesStatsRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState)
|
protected GroupShardsIterator |
TransportIndicesStatsAction.shards(ClusterState clusterState,
IndicesStatsRequest request,
String[] concreteIndices)
Status goes across *all* shards. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.status |
---|
Methods in org.elasticsearch.action.admin.indices.status with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndicesStatusAction.checkGlobalBlock(ClusterState state,
IndicesStatusRequest request)
|
protected ClusterBlockException |
TransportIndicesStatusAction.checkRequestBlock(ClusterState state,
IndicesStatusRequest countRequest,
String[] concreteIndices)
|
protected IndicesStatusResponse |
TransportIndicesStatusAction.newResponse(IndicesStatusRequest request,
AtomicReferenceArray shardsResponses,
ClusterState clusterState)
|
protected GroupShardsIterator |
TransportIndicesStatusAction.shards(ClusterState state,
IndicesStatusRequest request,
String[] concreteIndices)
Status goes across *all* shards. |
Uses of ClusterState in org.elasticsearch.action.admin.indices.template.delete |
---|
Methods in org.elasticsearch.action.admin.indices.template.delete with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportDeleteIndexTemplateAction.checkBlock(DeleteIndexTemplateRequest request,
ClusterState state)
|
protected DeleteIndexTemplateResponse |
TransportDeleteIndexTemplateAction.masterOperation(DeleteIndexTemplateRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.template.put |
---|
Methods in org.elasticsearch.action.admin.indices.template.put with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportPutIndexTemplateAction.checkBlock(PutIndexTemplateRequest request,
ClusterState state)
|
protected PutIndexTemplateResponse |
TransportPutIndexTemplateAction.masterOperation(PutIndexTemplateRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.validate.query |
---|
Methods in org.elasticsearch.action.admin.indices.validate.query with parameters of type ClusterState | |
---|---|
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)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.warmer.delete |
---|
Methods in org.elasticsearch.action.admin.indices.warmer.delete with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportDeleteWarmerAction.checkBlock(DeleteWarmerRequest request,
ClusterState state)
|
protected DeleteWarmerResponse |
TransportDeleteWarmerAction.masterOperation(DeleteWarmerRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.admin.indices.warmer.put |
---|
Methods in org.elasticsearch.action.admin.indices.warmer.put with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportPutWarmerAction.checkBlock(PutWarmerRequest request,
ClusterState state)
|
protected PutWarmerResponse |
TransportPutWarmerAction.masterOperation(PutWarmerRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.bulk |
---|
Methods in org.elasticsearch.action.bulk with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportShardBulkAction.checkGlobalBlock(ClusterState state,
BulkShardRequest request)
|
protected ClusterBlockException |
TransportShardBulkAction.checkRequestBlock(ClusterState state,
BulkShardRequest request)
|
protected TransportShardReplicationOperationAction.PrimaryResponse<BulkShardResponse,BulkShardRequest> |
TransportShardBulkAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
|
protected ShardIterator |
TransportShardBulkAction.shards(ClusterState clusterState,
BulkShardRequest request)
|
Uses of ClusterState in org.elasticsearch.action.count |
---|
Methods in org.elasticsearch.action.count with parameters of type ClusterState | |
---|---|
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)
|
Uses of ClusterState in org.elasticsearch.action.delete |
---|
Methods in org.elasticsearch.action.delete with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportDeleteAction.checkGlobalBlock(ClusterState state,
DeleteRequest request)
|
protected ClusterBlockException |
TransportDeleteAction.checkRequestBlock(ClusterState state,
DeleteRequest request)
|
protected boolean |
TransportDeleteAction.resolveRequest(ClusterState state,
DeleteRequest request,
ActionListener<DeleteResponse> listener)
|
protected TransportShardReplicationOperationAction.PrimaryResponse<DeleteResponse,DeleteRequest> |
TransportDeleteAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
|
protected ShardIterator |
TransportDeleteAction.shards(ClusterState clusterState,
DeleteRequest request)
|
Uses of ClusterState in org.elasticsearch.action.delete.index |
---|
Methods in org.elasticsearch.action.delete.index with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndexDeleteAction.checkGlobalBlock(ClusterState state,
IndexDeleteRequest request)
|
protected ClusterBlockException |
TransportShardDeleteAction.checkGlobalBlock(ClusterState state,
ShardDeleteRequest request)
|
protected ClusterBlockException |
TransportIndexDeleteAction.checkRequestBlock(ClusterState state,
IndexDeleteRequest request)
|
protected ClusterBlockException |
TransportShardDeleteAction.checkRequestBlock(ClusterState state,
ShardDeleteRequest request)
|
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteResponse,ShardDeleteRequest> |
TransportShardDeleteAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
|
protected ShardIterator |
TransportShardDeleteAction.shards(ClusterState clusterState,
ShardDeleteRequest request)
|
Uses of ClusterState in org.elasticsearch.action.deletebyquery |
---|
Uses of ClusterState in org.elasticsearch.action.explain |
---|
Methods in org.elasticsearch.action.explain with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportExplainAction.checkGlobalBlock(ClusterState state,
ExplainRequest request)
|
protected ClusterBlockException |
TransportExplainAction.checkRequestBlock(ClusterState state,
ExplainRequest request)
|
protected void |
TransportExplainAction.resolveRequest(ClusterState state,
ExplainRequest request)
|
protected ShardIterator |
TransportExplainAction.shards(ClusterState state,
ExplainRequest request)
|
Uses of ClusterState in org.elasticsearch.action.get |
---|
Methods in org.elasticsearch.action.get with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportGetAction.checkGlobalBlock(ClusterState state,
GetRequest request)
|
protected ClusterBlockException |
TransportShardMultiGetAction.checkGlobalBlock(ClusterState state,
MultiGetShardRequest request)
|
protected ClusterBlockException |
TransportGetAction.checkRequestBlock(ClusterState state,
GetRequest request)
|
protected ClusterBlockException |
TransportShardMultiGetAction.checkRequestBlock(ClusterState state,
MultiGetShardRequest request)
|
protected void |
TransportGetAction.resolveRequest(ClusterState state,
GetRequest request)
|
protected void |
TransportShardMultiGetAction.resolveRequest(ClusterState state,
MultiGetShardRequest request)
|
protected ShardIterator |
TransportGetAction.shards(ClusterState state,
GetRequest request)
|
protected ShardIterator |
TransportShardMultiGetAction.shards(ClusterState state,
MultiGetShardRequest request)
|
Uses of ClusterState in org.elasticsearch.action.index |
---|
Methods in org.elasticsearch.action.index with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportIndexAction.checkGlobalBlock(ClusterState state,
IndexRequest request)
|
protected ClusterBlockException |
TransportIndexAction.checkRequestBlock(ClusterState state,
IndexRequest request)
|
protected boolean |
TransportIndexAction.resolveRequest(ClusterState state,
IndexRequest request,
ActionListener<IndexResponse> indexResponseActionListener)
|
protected TransportShardReplicationOperationAction.PrimaryResponse<IndexResponse,IndexRequest> |
TransportIndexAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
|
protected ShardIterator |
TransportIndexAction.shards(ClusterState clusterState,
IndexRequest request)
|
Uses of ClusterState in org.elasticsearch.action.percolate |
---|
Methods in org.elasticsearch.action.percolate with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportPercolateAction.checkGlobalBlock(ClusterState state,
PercolateRequest request)
|
protected ClusterBlockException |
TransportPercolateAction.checkRequestBlock(ClusterState state,
PercolateRequest request)
|
protected ShardsIterator |
TransportPercolateAction.shards(ClusterState clusterState,
PercolateRequest request)
|
Uses of ClusterState in org.elasticsearch.action.search.type |
---|
Fields in org.elasticsearch.action.search.type declared as ClusterState | |
---|---|
protected ClusterState |
TransportSearchTypeAction.BaseAsyncAction.clusterState
|
Uses of ClusterState in org.elasticsearch.action.support.broadcast |
---|
Methods in org.elasticsearch.action.support.broadcast with parameters of type ClusterState | |
---|---|
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)
|
Uses of ClusterState in org.elasticsearch.action.support.master |
---|
Methods in org.elasticsearch.action.support.master with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportMasterNodeOperationAction.checkBlock(Request request,
ClusterState state)
|
protected abstract Response |
TransportMasterNodeOperationAction.masterOperation(Request request,
ClusterState state)
|
protected void |
TransportMasterNodeOperationAction.processBeforeDelegationToMaster(Request request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.action.support.replication |
---|
Methods in org.elasticsearch.action.support.replication with parameters of type ClusterState | |
---|---|
protected abstract ClusterBlockException |
TransportIndicesReplicationOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportIndexReplicationOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportShardReplicationOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportIndexReplicationOperationAction.checkRequestBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportShardReplicationOperationAction.checkRequestBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportIndicesReplicationOperationAction.checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices)
|
protected boolean |
TransportShardReplicationOperationAction.resolveRequest(ClusterState state,
Request request,
ActionListener<Response> listener)
Resolves the request, by default, simply setting the concrete index (if its aliased one). |
protected abstract TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest> |
TransportShardReplicationOperationAction.shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
|
protected abstract ShardIterator |
TransportShardReplicationOperationAction.shards(ClusterState clusterState,
Request request)
|
Uses of ClusterState in org.elasticsearch.action.support.single.custom |
---|
Methods in org.elasticsearch.action.support.single.custom with parameters of type ClusterState | |
---|---|
protected abstract ClusterBlockException |
TransportSingleCustomOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportSingleCustomOperationAction.checkRequestBlock(ClusterState state,
Request request)
|
protected abstract ShardsIterator |
TransportSingleCustomOperationAction.shards(ClusterState state,
Request request)
Can return null to execute on this local node. |
Uses of ClusterState in org.elasticsearch.action.support.single.instance |
---|
Methods in org.elasticsearch.action.support.single.instance with parameters of type ClusterState | |
---|---|
protected abstract ClusterBlockException |
TransportInstanceSingleOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportInstanceSingleOperationAction.checkRequestBlock(ClusterState state,
Request request)
|
protected boolean |
TransportInstanceSingleOperationAction.resolveRequest(ClusterState state,
Request request,
ActionListener<Response> listener)
Resolves the request, by default, simply setting the concrete index (if its aliased one). |
protected abstract ShardIterator |
TransportInstanceSingleOperationAction.shards(ClusterState clusterState,
Request request)
Should return an iterator with a single shard! |
Uses of ClusterState in org.elasticsearch.action.support.single.shard |
---|
Methods in org.elasticsearch.action.support.single.shard with parameters of type ClusterState | |
---|---|
protected abstract ClusterBlockException |
TransportShardSingleOperationAction.checkGlobalBlock(ClusterState state,
Request request)
|
protected abstract ClusterBlockException |
TransportShardSingleOperationAction.checkRequestBlock(ClusterState state,
Request request)
|
protected void |
TransportShardSingleOperationAction.resolveRequest(ClusterState state,
Request request)
|
protected abstract ShardIterator |
TransportShardSingleOperationAction.shards(ClusterState state,
Request request)
|
Uses of ClusterState in org.elasticsearch.action.update |
---|
Methods in org.elasticsearch.action.update with parameters of type ClusterState | |
---|---|
protected ClusterBlockException |
TransportUpdateAction.checkGlobalBlock(ClusterState state,
UpdateRequest request)
|
protected ClusterBlockException |
TransportUpdateAction.checkRequestBlock(ClusterState state,
UpdateRequest request)
|
protected boolean |
TransportUpdateAction.resolveRequest(ClusterState state,
UpdateRequest request,
ActionListener<UpdateResponse> listener)
|
protected ShardIterator |
TransportUpdateAction.shards(ClusterState clusterState,
UpdateRequest request)
|
Uses of ClusterState in org.elasticsearch.cluster |
---|
Methods in org.elasticsearch.cluster that return ClusterState | |
---|---|
ClusterState |
ClusterState.Builder.build()
|
ClusterState |
ClusterStateUpdateTask.execute(ClusterState currentState)
Update the cluster state based on the current state. |
static ClusterState |
ClusterState.Builder.fromBytes(byte[] data,
DiscoveryNode localNode)
|
ClusterState |
ClusterChangedEvent.previousState()
|
static ClusterState |
ClusterState.Builder.readFrom(StreamInput in,
DiscoveryNode localNode)
|
ClusterState |
ClusterState.settingsFilter(SettingsFilter settingsFilter)
|
ClusterState |
ClusterService.state()
The current state. |
ClusterState |
ClusterChangedEvent.state()
|
Methods in org.elasticsearch.cluster with parameters of type ClusterState | |
---|---|
void |
ProcessedClusterStateUpdateTask.clusterStateProcessed(ClusterState clusterState)
Called when the result of the ClusterStateUpdateTask.execute(ClusterState) have been processed
properly by all listeners. |
ClusterState |
ClusterStateUpdateTask.execute(ClusterState currentState)
Update the cluster state based on the current state. |
ClusterState.Builder |
ClusterState.Builder.state(ClusterState state)
|
static byte[] |
ClusterState.Builder.toBytes(ClusterState state)
|
static void |
ClusterState.Builder.writeTo(ClusterState state,
StreamOutput out)
|
Constructors in org.elasticsearch.cluster with parameters of type ClusterState | |
---|---|
ClusterChangedEvent(String source,
ClusterState state,
ClusterState previousState)
|
|
ClusterState(long version,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.cluster.action.index |
---|
Methods in org.elasticsearch.cluster.action.index with parameters of type ClusterState | |
---|---|
protected MappingUpdatedAction.MappingUpdatedResponse |
MappingUpdatedAction.masterOperation(MappingUpdatedAction.MappingUpdatedRequest request,
ClusterState state)
|
Uses of ClusterState in org.elasticsearch.cluster.routing |
---|
Methods in org.elasticsearch.cluster.routing with parameters of type ClusterState | |
---|---|
RoutingNodes |
RoutingTable.routingNodes(ClusterState state)
|
Constructors in org.elasticsearch.cluster.routing with parameters of type ClusterState | |
---|---|
RoutingNodes(ClusterState clusterState)
|
Uses of ClusterState in org.elasticsearch.cluster.routing.allocation |
---|
Methods in org.elasticsearch.cluster.routing.allocation with parameters of type ClusterState | |
---|---|
RoutingAllocation.Result |
AllocationService.applyFailedShard(ClusterState clusterState,
ShardRouting failedShard)
Applies the failed shards. |
RoutingAllocation.Result |
AllocationService.applyStartedShards(ClusterState clusterState,
List<? extends ShardRouting> startedShards)
Applies the started shards. |
RoutingAllocation.Result |
AllocationService.reroute(ClusterState clusterState)
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. |
Uses of ClusterState in org.elasticsearch.cluster.routing.operation |
---|
Methods in org.elasticsearch.cluster.routing.operation with parameters of type ClusterState | |
---|---|
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,
String queryHint,
Map<String,Set<String>> routing,
String preference)
|
int |
OperationRouting.searchShardsCount(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
String queryHint,
Map<String,Set<String>> routing,
String preference)
|
Uses of ClusterState in org.elasticsearch.cluster.routing.operation.plain |
---|
Methods in org.elasticsearch.cluster.routing.operation.plain with parameters of type ClusterState | |
---|---|
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,
String queryHint,
Map<String,Set<String>> routing,
String preference)
|
int |
PlainOperationRouting.searchShardsCount(ClusterState clusterState,
String[] indices,
String[] concreteIndices,
String queryHint,
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)
|
Uses of ClusterState in org.elasticsearch.cluster.service |
---|
Methods in org.elasticsearch.cluster.service that return ClusterState | |
---|---|
ClusterState |
InternalClusterService.state()
|
Uses of ClusterState in org.elasticsearch.discovery |
---|
Methods in org.elasticsearch.discovery with parameters of type ClusterState | |
---|---|
void |
DiscoveryService.publish(ClusterState clusterState)
Publish all the changes to the cluster from the master (can be called just by the master). |
void |
Discovery.publish(ClusterState clusterState)
Publish all the changes to the cluster from the master (can be called just by the master). |
Uses of ClusterState in org.elasticsearch.discovery.local |
---|
Methods in org.elasticsearch.discovery.local with parameters of type ClusterState | |
---|---|
void |
LocalDiscovery.publish(ClusterState clusterState)
|
Uses of ClusterState in org.elasticsearch.discovery.zen |
---|
Methods in org.elasticsearch.discovery.zen with parameters of type ClusterState | |
---|---|
void |
ZenDiscovery.publish(ClusterState clusterState)
|
Uses of ClusterState in org.elasticsearch.discovery.zen.membership |
---|
Methods in org.elasticsearch.discovery.zen.membership that return ClusterState | |
---|---|
ClusterState |
MembershipAction.MembershipListener.onJoin(DiscoveryNode node)
|
ClusterState |
MembershipAction.sendJoinRequestBlocking(DiscoveryNode masterNode,
DiscoveryNode node,
TimeValue timeout)
|
Methods in org.elasticsearch.discovery.zen.membership with parameters of type ClusterState | |
---|---|
void |
MembershipAction.sendValidateJoinRequestBlocking(DiscoveryNode node,
ClusterState clusterState,
TimeValue timeout)
Validates the join request, throwing a failure if it failed. |
Uses of ClusterState in org.elasticsearch.discovery.zen.publish |
---|
Methods in org.elasticsearch.discovery.zen.publish with parameters of type ClusterState | |
---|---|
void |
PublishClusterStateAction.NewClusterStateListener.onNewClusterState(ClusterState clusterState)
|
void |
PublishClusterStateAction.publish(ClusterState clusterState)
|
Uses of ClusterState in org.elasticsearch.gateway |
---|
Methods in org.elasticsearch.gateway with parameters of type ClusterState | |
---|---|
void |
Gateway.GatewayStateRecoveredListener.onSuccess(ClusterState recoveredState)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |