Module org.elasticsearch.server
Package org.elasticsearch.index.seqno
Class RetentionLeaseActions.TransportAddAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<RetentionLeaseActions.AddRequest,ActionResponse.Empty>
org.elasticsearch.action.support.single.shard.TransportSingleShardAction<RetentionLeaseActions.AddRequest,ActionResponse.Empty>
org.elasticsearch.index.seqno.RetentionLeaseActions.TransportAddAction
- Enclosing class:
RetentionLeaseActions
public static class RetentionLeaseActions.TransportAddAction
extends TransportSingleShardAction<RetentionLeaseActions.AddRequest,ActionResponse.Empty>
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
TransportSingleShardAction.InternalRequest -
Field Summary
Fields inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
clusterService, indexNameExpressionResolver, projectResolver, threadPool, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportAddAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver, IndicesService indicesService) -
Method Summary
Modifier and TypeMethodDescriptionprotected voidasyncShardOperation(RetentionLeaseActions.AddRequest request, ShardId shardId, ActionListener<ActionResponse.Empty> listener) protected final Writeable.Reader<ActionResponse.Empty> protected booleanprotected ActionResponse.EmptyshardOperation(RetentionLeaseActions.AddRequest request, ShardId shardId) protected ShardsIteratorshards(ProjectState state, TransportSingleShardAction<RetentionLeaseActions.AddRequest, ActionResponse.Empty>.InternalRequest request) Returns the candidate shards to execute the operation on ornullthe execute the operation locally (the node that received the request)Methods inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
checkGlobalBlock, checkRequestBlock, doExecute, getExecutor, getProjectState, isSubAction, resolveRequestMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Constructor Details
-
TransportAddAction
@Inject public TransportAddAction(ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver, IndicesService indicesService)
-
-
Method Details
-
shards
protected ShardsIterator shards(ProjectState state, TransportSingleShardAction<RetentionLeaseActions.AddRequest, ActionResponse.Empty>.InternalRequest request) Description copied from class:TransportSingleShardActionReturns the candidate shards to execute the operation on ornullthe execute the operation locally (the node that received the request)- Specified by:
shardsin classTransportSingleShardAction<T extends org.elasticsearch.index.seqno.RetentionLeaseActions.Request<T>,ActionResponse.Empty>
-
asyncShardOperation
protected void asyncShardOperation(RetentionLeaseActions.AddRequest request, ShardId shardId, ActionListener<ActionResponse.Empty> listener) - Overrides:
asyncShardOperationin classTransportSingleShardAction<T extends org.elasticsearch.index.seqno.RetentionLeaseActions.Request<T>,ActionResponse.Empty>
-
shardOperation
protected ActionResponse.Empty shardOperation(RetentionLeaseActions.AddRequest request, ShardId shardId) - Specified by:
shardOperationin classTransportSingleShardAction<T extends org.elasticsearch.index.seqno.RetentionLeaseActions.Request<T>,ActionResponse.Empty>
-
getResponseReader
- Specified by:
getResponseReaderin classTransportSingleShardAction<T extends org.elasticsearch.index.seqno.RetentionLeaseActions.Request<T>,ActionResponse.Empty>
-
resolveIndex
- Specified by:
resolveIndexin classTransportSingleShardAction<T extends org.elasticsearch.index.seqno.RetentionLeaseActions.Request<T>,ActionResponse.Empty>
-