Module org.elasticsearch.server
Package org.elasticsearch.action.support
package org.elasticsearch.action.support
-
ClassDescriptionAbstractThreadedActionListener<Response>Base class for action listeners that wrap another action listener and dispatch its completion to an executor.A filter allowing to filter transport actionsA simple base class for injectable action filters that spares the implementation from handling the filter chain.A filter chain allowing to continue and process the transport action requestHolds the action filters injected through plugins, properly sorted by
ActionFilter.order()
A class whose instances represent a value for counting the number of active shard copies for a given shard in an index.Record that captures the decision ofActiveShardCount.enoughShardsActive(IndexShardRoutingTable)
.This utility class provides a primitive for waiting for a configured number of shards to become active before sending a response on anActionListener
.Encapsulates the logic of whether a new index should be automatically created when a write operation is about to happen in a non existing index.CancellableFanOut<Item,ItemResponse, FinalResponse> Allows an action to fan-out to several sub-actions and accumulate their results, but which reacts to a cancellation by releasing all references to itself, and hence the partially-accumulated results, allowing them to be garbage-collected.ChannelActionListener<Response extends TransportResponse>Restores the givenThreadContext.StoredContext
once the listener is invokedWraps another listener and adds a counter -- each invocation of this listener will decrement the counter, and when the counter has been exhausted the final invocation of this listener will delegate to the wrapped listener.Helper for dealing with destructive operations and wildcard usage.An action listener that delegates its results to another listener once it has received N results (either successes or failures).ATransportAction
which, on creation, registers a handler for its ownTransportAction.actionName
with the transport service.Contains all the multi-target syntax options.Controls the way the target indices will be handled.Applies to all indices already matched and controls the type of indices that will be returned.The "gatekeeper" options apply on all indices that have been selected by the other Options.Controls the way the wildcard expressions will be resolved.AnActionListener
which allows for the result to fan out to a (dynamic) collection of other listeners, added usingSubscribableListener.addListener(org.elasticsearch.action.ActionListener<T>)
.RefCountAwareThreadedActionListener<Response extends RefCounted>Same asThreadedActionListener
but forRefCounted
types.A mechanism to complete a listener on the completion of some (dynamic) collection of other actions.A mechanism to trigger an action on the completion of some (dynamic) collection of other actions.ReservedStateAwareHandledTransportAction<Request extends ActionRequest,Response extends ActionResponse> An extension of theHandledTransportAction
class, which wraps the doExecute call with a check for clashes with the reserved cluster state.RetryableAction<Response>A action that will be retried on failure ifRetryableAction.shouldRetry(Exception)
returns true.AnActionListener
to which otherActionListener
instances can subscribe, such that when this listener is completed it fans-out its result to the subscribed listeners.ThreadedActionListener<Response>An action listener that wraps another action listener and dispatches its completion to an executor.Analogue ofTransportMasterNodeReadAction
except that it runs on the local node rather than delegating to the master.WriteRequest<R extends WriteRequest<R>>Interface implemented by requests that modify the documents in an index likeIndexRequest
,UpdateRequest
, andBulkRequest
.WriteRequestBuilder<B extends WriteRequestBuilder<B>>Interface implemented by responses for actions that modify the documents in an index likeIndexResponse
,UpdateResponse
, andBulkResponse
.