Class StartRecoveryRequest
- java.lang.Object
-
- org.elasticsearch.transport.TransportMessage
-
- org.elasticsearch.transport.TransportRequest
-
- org.elasticsearch.indices.recovery.StartRecoveryRequest
-
- All Implemented Interfaces:
Writeable
,TaskAwareRequest
public class StartRecoveryRequest extends TransportRequest
Represents a request for starting a peer recovery.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportRequest
TransportRequest.Empty
-
Nested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V>
-
-
Constructor Summary
Constructors Constructor Description StartRecoveryRequest(StreamInput in)
StartRecoveryRequest(ShardId shardId, java.lang.String targetAllocationId, DiscoveryNode sourceNode, DiscoveryNode targetNode, Store.MetadataSnapshot metadataSnapshot, boolean primaryRelocation, long recoveryId, long startingSeqNo)
Construct a request for starting a peer recovery.
-
Method Summary
Modifier and Type Method Description boolean
isPrimaryRelocation()
Store.MetadataSnapshot
metadataSnapshot()
long
recoveryId()
ShardId
shardId()
DiscoveryNode
sourceNode()
long
startingSeqNo()
java.lang.String
targetAllocationId()
DiscoveryNode
targetNode()
void
writeTo(StreamOutput out)
Write this into the StreamOutput.-
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.tasks.TaskAwareRequest
createTask, getDescription, setParentTask
-
-
-
-
Constructor Detail
-
StartRecoveryRequest
public StartRecoveryRequest(StreamInput in) throws java.io.IOException
- Throws:
java.io.IOException
-
StartRecoveryRequest
public StartRecoveryRequest(ShardId shardId, java.lang.String targetAllocationId, DiscoveryNode sourceNode, DiscoveryNode targetNode, Store.MetadataSnapshot metadataSnapshot, boolean primaryRelocation, long recoveryId, long startingSeqNo)
Construct a request for starting a peer recovery.- Parameters:
shardId
- the shard ID to recovertargetAllocationId
- the allocation id of the target shardsourceNode
- the source node to remover fromtargetNode
- the target node to recover tometadataSnapshot
- the Lucene metadataprimaryRelocation
- whether or not the recovery is a primary relocationrecoveryId
- the recovery IDstartingSeqNo
- the starting sequence number
-
-
Method Detail
-
recoveryId
public long recoveryId()
-
shardId
public ShardId shardId()
-
targetAllocationId
public java.lang.String targetAllocationId()
-
sourceNode
public DiscoveryNode sourceNode()
-
targetNode
public DiscoveryNode targetNode()
-
isPrimaryRelocation
public boolean isPrimaryRelocation()
-
metadataSnapshot
public Store.MetadataSnapshot metadataSnapshot()
-
startingSeqNo
public long startingSeqNo()
-
writeTo
public void writeTo(StreamOutput out) throws java.io.IOException
Description copied from interface:Writeable
Write this into the StreamOutput.- Specified by:
writeTo
in interfaceWriteable
- Overrides:
writeTo
in classTransportRequest
- Throws:
java.io.IOException
-
-