org.elasticsearch.action.support.master

Class AcknowledgedRequest<Request extends MasterNodeRequest<Request>>

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportRequest

org.elasticsearch.action.ActionRequest

org.elasticsearch.action.support.master.MasterNodeRequest<Request>

org.elasticsearch.action.support.master.AcknowledgedRequest<Request>

All Implemented Interfaces:

AckedRequest, Streamable, TaskAwareRequest

Direct Known Subclasses:

CloseIndexRequest, ClusterRerouteRequest, ClusterUpdateSettingsRequest, CreateIndexRequest, DeleteIndexRequest, DeletePipelineRequest, DeleteRepositoryRequest, DeleteStoredScriptRequest, IndicesAliasesRequest, OpenIndexRequest, PutMappingRequest, PutPipelineRequest, PutRepositoryRequest, PutStoredScriptRequest, RolloverRequest, ShrinkRequest, UpdateSettingsRequest, UpgradeSettingsRequest, VerifyRepositoryRequest

public abstract class AcknowledgedRequest<Request extends MasterNodeRequest<Request>>
extends MasterNodeRequest<Request>
implements AckedRequest

Abstract class that allows to mark action requests that support acknowledgements. Facilitates consistency across different api.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportRequest

TransportRequest.Empty

Field Summary

Fields

Modifier and Type	Field and Description
static TimeValue	DEFAULT_ACK_TIMEOUT
protected TimeValue	timeout

Fields inherited from class org.elasticsearch.action.support.master.MasterNodeRequest

DEFAULT_MASTER_NODE_TIMEOUT, masterNodeTimeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AcknowledgedRequest()

Method Summary

Modifier and Type	Method and Description
TimeValue	ackTimeout() Returns the acknowledgement timeout
protected void	readTimeout(StreamInput in) Reads the timeout value
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
protected void	writeTimeout(StreamOutput out) writes the timeout value

Methods inherited from class org.elasticsearch.action.support.master.MasterNodeRequest

masterNodeTimeout, masterNodeTimeout, masterNodeTimeout, readFrom, writeTo

Methods inherited from class org.elasticsearch.action.ActionRequest

getShouldStoreResult, validate

Methods inherited from class org.elasticsearch.transport.TransportRequest

getParentTask, setParentTask

Methods inherited from class org.elasticsearch.transport.TransportMessage

remoteAddress, remoteAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.cluster.ack.AckedRequest

masterNodeTimeout

Methods inherited from interface org.elasticsearch.tasks.TaskAwareRequest

createTask, getDescription, setParentTask

Field Detail

DEFAULT_ACK_TIMEOUT

public static final TimeValue DEFAULT_ACK_TIMEOUT

timeout

protected TimeValue timeout

Constructor Detail

AcknowledgedRequest

protected AcknowledgedRequest()

Method Detail

timeout

public final Request timeout(java.lang.String timeout)

Allows to set the timeout

Parameters:

timeout - timeout as a string (e.g. 1s)

Returns:

the request itself

timeout

public final Request timeout(TimeValue timeout)

Allows to set the timeout

Parameters:

timeout - timeout as a TimeValue

Returns:

the request itself

timeout

public final TimeValue timeout()

Returns the current timeout

Returns:

the current timeout as a TimeValue

readTimeout

protected void readTimeout(StreamInput in)
                    throws java.io.IOException

Reads the timeout value

Throws:

java.io.IOException

writeTimeout

protected void writeTimeout(StreamOutput out)
                     throws java.io.IOException

writes the timeout value

Throws:

java.io.IOException

ackTimeout

public TimeValue ackTimeout()

Description copied from interface: AckedRequest

Returns the acknowledgement timeout

Specified by:

ackTimeout in interface AckedRequest