public class StartRecoveryRequest extends TransportRequest
TransportRequest.Empty headers| Constructor and Description |
|---|
StartRecoveryRequest(ShardId
Start recovery request.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
markAsRelocated()
|
Store |
metadataSnapshot()
|
void |
readFrom(StreamInput
|
long |
recoveryId()
|
RecoveryState |
recoveryType()
|
ShardId |
shardId()
|
DiscoveryNode |
sourceNode()
|
DiscoveryNode |
targetNode()
|
void |
writeTo(StreamOutput
|
putHeader, remoteAddress, remoteAddresscontextSize, copyContextAndHeadersFrom, copyContextFrom, copyHeadersFrom, getContext, getFromContext, getFromContext, getHeader, getHeaders, hasHeader, hasInContext, isContextEmpty, putAllInContext, putInContextpublic StartRecoveryRequest(ShardIdshardId, DiscoveryNode sourceNode, DiscoveryNode targetNode, boolean markAsRelocated, Store .MetadataSnapshot metadataSnapshot, RecoveryState .Type recoveryType, long recoveryId)
shardId -
sourceNode - The node to recover from
targetNode - The node to recover to
markAsRelocated -
metadataSnapshot -
public long recoveryId()
public ShardIdshardId()
public DiscoveryNodesourceNode()
public DiscoveryNodetargetNode()
public boolean markAsRelocated()
public RecoveryState.Type recoveryType()
public Store.MetadataSnapshot metadataSnapshot()
public void readFrom(StreamInputin) throws IOException
readFrom in interface
Streamable
readFrom in class
TransportMessage<TransportRequest>
IOException
public void writeTo(StreamOutputout) throws IOException
writeTo in interface
Streamable
writeTo in class
TransportMessage<TransportRequest>
IOException