Module org.elasticsearch.xcore

Package org.elasticsearch.xpack.core.ccr.action

Class ShardFollowTask

java.lang.Object

org.elasticsearch.xpack.core.ccr.action.ImmutableFollowParameters

org.elasticsearch.xpack.core.ccr.action.ShardFollowTask

All Implemented Interfaces:

NamedWriteable, VersionedNamedWriteable, Writeable, PersistentTaskParams, ToXContent, ToXContentObject

public class ShardFollowTask
extends ImmutableFollowParameters
implements PersistentTaskParams

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent

ToXContent.DelegatingMapParams, ToXContent.MapParams, ToXContent.Params

Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable

Writeable.Reader<V>, Writeable.Writer<V>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME

Fields inherited from interface org.elasticsearch.xcontent.ToXContent

EMPTY, EMPTY_PARAMS

Constructor Summary

Constructors

Constructor

Description

ShardFollowTask(String remoteCluster, ShardId followShardId, ShardId leaderShardId, int maxReadRequestOperationCount, int maxWriteRequestOperationCount, int maxOutstandingReadRequests, int maxOutstandingWriteRequests, ByteSizeValue maxReadRequestSize, ByteSizeValue maxWriteRequestSize, int maxWriteBufferCount, ByteSizeValue maxWriteBufferSize, TimeValue maxRetryDelay, TimeValue readPollTimeout, Map<String,String> headers)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static ShardFollowTask	fromXContent(XContentParser parser)
ShardId	getFollowShardId()
Map<String,String>	getHeaders()
ShardId	getLeaderShardId()
TransportVersion	getMinimalSupportedVersion()
String	getRemoteCluster()
String	getWriteableName()
int	hashCode()
static ShardFollowTask	readFrom(StreamInput in)
String	toString()
XContentBuilder	toXContent(XContentBuilder builder, ToXContent.Params params)
void	writeTo(StreamOutput out)

Methods inherited from class org.elasticsearch.xpack.core.ccr.action.ImmutableFollowParameters

getMaxOutstandingReadRequests, getMaxOutstandingWriteRequests, getMaxReadRequestOperationCount, getMaxReadRequestSize, getMaxRetryDelay, getMaxWriteBufferCount, getMaxWriteBufferSize, getMaxWriteRequestOperationCount, getMaxWriteRequestSize, getReadPollTimeout, initParser, toXContentFragment

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.xcontent.ToXContentObject

isFragment

Methods inherited from interface org.elasticsearch.common.io.stream.VersionedNamedWriteable

supportsVersion

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

Constructor Details

ShardFollowTask

public ShardFollowTask(String remoteCluster,
 ShardId followShardId,
 ShardId leaderShardId,
 int maxReadRequestOperationCount,
 int maxWriteRequestOperationCount,
 int maxOutstandingReadRequests,
 int maxOutstandingWriteRequests,
 ByteSizeValue maxReadRequestSize,
 ByteSizeValue maxWriteRequestSize,
 int maxWriteBufferCount,
 ByteSizeValue maxWriteBufferSize,
 TimeValue maxRetryDelay,
 TimeValue readPollTimeout,
 Map<String,String> headers)

Method Details

readFrom

public static ShardFollowTask readFrom(StreamInput in)
                                throws IOException

Throws:

IOException

getRemoteCluster

public String getRemoteCluster()

getFollowShardId

public ShardId getFollowShardId()

getLeaderShardId

public ShardId getLeaderShardId()

getHeaders

public Map<String,String> getHeaders()

getWriteableName

public String getWriteableName()

Specified by:

getWriteableName in interface NamedWriteable

Specified by:

getWriteableName in interface VersionedNamedWriteable

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Specified by:

writeTo in interface Writeable

Overrides:

writeTo in class ImmutableFollowParameters

Throws:

IOException

fromXContent

public static ShardFollowTask fromXContent(XContentParser parser)

toXContent

public XContentBuilder toXContent(XContentBuilder builder,
 ToXContent.Params params)
                           throws IOException

Specified by:

toXContent in interface ToXContent

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class ImmutableFollowParameters

hashCode

public int hashCode()

Overrides:

hashCode in class ImmutableFollowParameters

toString

public String toString()

Overrides:

toString in class Object

getMinimalSupportedVersion

public TransportVersion getMinimalSupportedVersion()

Specified by:

getMinimalSupportedVersion in interface VersionedNamedWriteable