public abstract class IndexReplicationOperationRequest<T extends IndexReplicationOperationRequest> extends ActionRequest<T> implements IndicesRequest
TransportIndexReplicationOperationAction
.
Since the corresponding action is internal that gets always executed locally, this request never gets sent over the transport.
The specified index is expected to be a concrete index. Relies on input validation done by the caller actions.TransportRequest.Empty
IndicesRequest.Replaceable
Modifier | Constructor and Description |
---|---|
protected |
IndexReplicationOperationRequest(String index,
TimeValue timeout,
ReplicationType replicationType,
WriteConsistencyLevel consistencyLevel,
String[] originalIndices,
IndicesOptions originalIndicesOptions,
ActionRequest request) |
Modifier and Type | Method and Description |
---|---|
WriteConsistencyLevel |
consistencyLevel() |
String |
index() |
String[] |
indices()
Returns the array of indices that the action relates to
|
IndicesOptions |
indicesOptions()
Returns the indices options used to resolve indices.
|
void |
readFrom(StreamInput in) |
ReplicationType |
replicationType() |
TimeValue |
timeout() |
ActionRequestValidationException |
validate() |
void |
writeTo(StreamOutput out) |
listenerThreaded, listenerThreaded
getHeader, getHeaders, hasHeader, putHeader, remoteAddress, remoteAddress
contextSize, copyContextFrom, getContext, getFromContext, getFromContext, hasInContext, isContextEmpty, putAllInContext, putInContext
protected IndexReplicationOperationRequest(String index, TimeValue timeout, ReplicationType replicationType, WriteConsistencyLevel consistencyLevel, String[] originalIndices, IndicesOptions originalIndicesOptions, ActionRequest request)
public ActionRequestValidationException validate()
validate
in class ActionRequest<T extends IndexReplicationOperationRequest>
public TimeValue timeout()
public String index()
public String[] indices()
IndicesRequest
indices
in interface IndicesRequest
public IndicesOptions indicesOptions()
IndicesRequest
indicesOptions
in interface IndicesRequest
public ReplicationType replicationType()
public WriteConsistencyLevel consistencyLevel()
public final void readFrom(StreamInput in) throws IOException
readFrom
in interface Streamable
readFrom
in class ActionRequest<T extends IndexReplicationOperationRequest>
IOException
public final void writeTo(StreamOutput out) throws IOException
writeTo
in interface Streamable
writeTo
in class ActionRequest<T extends IndexReplicationOperationRequest>
IOException
Copyright © 2009–2015. All rights reserved.