Constructor Detail

• TransportRefreshAction

  @Inject
  public TransportRefreshAction(Settings settings,
                                        ThreadPool threadPool,
                                        ClusterService clusterService,
                                        TransportService transportService,
                                        IndicesService indicesService,
                                        ActionFilters actionFilters)

Method Detail

• executor

  protected String executor()

• newRequest

  protected RefreshRequest newRequest()

• newResponse

  protected RefreshResponse newResponse(RefreshRequest request,
                                        AtomicReferenceArray shardsResponses,
                                        ClusterState clusterState)

• newShardRequest

  protected org.elasticsearch.action.admin.indices.refresh.ShardRefreshRequest newShardRequest()

• newShardRequest

  protected org.elasticsearch.action.admin.indices.refresh.ShardRefreshRequest newShardRequest(int numShards,
                                                                                               ShardRouting shard,
                                                                                               RefreshRequest request)

• newShardResponse

  protected org.elasticsearch.action.admin.indices.refresh.ShardRefreshResponse newShardResponse()

• shardOperation

  protected org.elasticsearch.action.admin.indices.refresh.ShardRefreshResponse shardOperation(org.elasticsearch.action.admin.indices.refresh.ShardRefreshRequest request)
                                                                                        throws ElasticsearchException

  Specified by:

  shardOperation in class  TransportBroadcastOperationAction<RefreshRequest,RefreshResponse,org.elasticsearch.action.admin.indices.refresh.ShardRefreshRequest,org.elasticsearch.action.admin.indices.refresh.ShardRefreshResponse>

  Throws:

  ElasticsearchException

• shards

  protected GroupShardsIterator shards(ClusterState clusterState,
                                       RefreshRequest request,
                                       String[] concreteIndices)

  The refresh request works against *all* shards.

• checkGlobalBlock

  protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                   RefreshRequest request)

• checkRequestBlock

  protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                    RefreshRequest countRequest,
                                                    String[] concreteIndices)