Class ReestablishRecoveryRequest

java.lang.Object
org.elasticsearch.transport.TransportMessage
org.elasticsearch.transport.TransportRequest
org.elasticsearch.indices.recovery.ReestablishRecoveryRequest
All Implemented Interfaces:
Writeable, org.elasticsearch.common.util.concurrent.RefCounted, TaskAwareRequest

public class ReestablishRecoveryRequest
extends TransportRequest
Represents a request for starting a peer recovery.
  • Constructor Details

    • ReestablishRecoveryRequest

      public ReestablishRecoveryRequest​(StreamInput in) throws java.io.IOException
      Throws:
      java.io.IOException
    • ReestablishRecoveryRequest

      public ReestablishRecoveryRequest​(long recoveryId, ShardId shardId, java.lang.String targetAllocationId)
  • Method Details

    • recoveryId

      public long recoveryId()
    • shardId

      public ShardId shardId()
    • targetAllocationId

      public java.lang.String targetAllocationId()
    • writeTo

      public void writeTo​(StreamOutput out) throws java.io.IOException
      Description copied from interface: Writeable
      Write this into the StreamOutput.
      Specified by:
      writeTo in interface Writeable
      Overrides:
      writeTo in class TransportRequest
      Throws:
      java.io.IOException