AckedRequest
, Streamable
, Writeable
, TaskAwareRequest
CloseIndexRequest
, ClusterRerouteRequest
, ClusterUpdateSettingsRequest
, CreateIndexRequest
, DeleteIndexRequest
, DeletePipelineRequest
, DeleteRepositoryRequest
, DeleteStoredScriptRequest
, IndicesAliasesRequest
, OpenIndexRequest
, PutMappingRequest
, PutPipelineRequest
, PutRepositoryRequest
, PutStoredScriptRequest
, ResizeRequest
, RolloverRequest
, UpdateSettingsRequest
, UpgradeSettingsRequest
, VerifyRepositoryRequest
public abstract class AcknowledgedRequest<Request extends MasterNodeRequest<Request>> extends MasterNodeRequest<Request> implements AckedRequest
TransportRequest.Empty
Writeable.Reader<V>, Writeable.Writer<V>
Modifier and Type | Field | Description |
---|---|---|
static TimeValue |
DEFAULT_ACK_TIMEOUT |
|
protected TimeValue |
timeout |
DEFAULT_MASTER_NODE_TIMEOUT, masterNodeTimeout
Modifier | Constructor | Description |
---|---|---|
protected |
AcknowledgedRequest() |
Modifier and Type | Method | Description |
---|---|---|
TimeValue |
ackTimeout() |
Returns the acknowledgement timeout
|
void |
readFrom(StreamInput in) |
Set this object's fields from a StreamInput.
|
TimeValue |
timeout() |
Returns the current timeout
|
Request |
timeout(java.lang.String timeout) |
Allows to set the timeout
|
Request |
timeout(TimeValue timeout) |
Allows to set the timeout
|
void |
writeTo(StreamOutput out) |
Write this object's fields to a StreamOutput.
|
masterNodeTimeout
getShouldStoreResult, validate
masterNodeTimeout, masterNodeTimeout, masterNodeTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTask, getDescription, setParentTask
remoteAddress, remoteAddress
getParentTask, setParentTask
public static final TimeValue DEFAULT_ACK_TIMEOUT
protected TimeValue timeout
public final Request timeout(java.lang.String timeout)
timeout
- timeout as a string (e.g. 1s)public final Request timeout(TimeValue timeout)
timeout
- timeout as a TimeValue
public final TimeValue timeout()
TimeValue
public TimeValue ackTimeout()
AckedRequest
ackTimeout
in interface AckedRequest
public void readFrom(StreamInput in) throws java.io.IOException
Streamable
readFrom
in interface Streamable
readFrom
in class MasterNodeRequest<Request extends MasterNodeRequest<Request>>
java.io.IOException
public void writeTo(StreamOutput out) throws java.io.IOException
Streamable
writeTo
in interface Streamable
writeTo
in interface Writeable
writeTo
in class MasterNodeRequest<Request extends MasterNodeRequest<Request>>
java.io.IOException