Class TestReplicationSource

java.lang.Object
org.opensearch.index.replication.TestReplicationSource
All Implemented Interfaces:
org.opensearch.indices.replication.SegmentReplicationSource
public abstract class TestReplicationSource extends Object implements org.opensearch.indices.replication.SegmentReplicationSource
This class is used by unit tests implementing SegmentReplicationSource

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.opensearch.indices.replication.SegmentReplicationSource

    org.opensearch.indices.replication.SegmentReplicationSource.ReplicationStatsDirectoryWrapper

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestReplicationSource()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    abstract void
    getCheckpointMetadata(long replicationId, org.opensearch.indices.replication.checkpoint.ReplicationCheckpoint checkpoint, org.opensearch.core.action.ActionListener<org.opensearch.indices.replication.CheckpointInfoResponse> listener)
     
    String
    getDescription()
     
    abstract void
    getSegmentFiles(long replicationId, org.opensearch.indices.replication.checkpoint.ReplicationCheckpoint checkpoint, List<org.opensearch.index.store.StoreFileMetadata> filesToFetch, org.opensearch.index.shard.IndexShard indexShard, BiConsumer<String,Long> fileProgressTracker, org.opensearch.core.action.ActionListener<org.opensearch.indices.replication.GetSegmentFilesResponse> listener)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.opensearch.indices.replication.SegmentReplicationSource

    cancel, getMergedSegmentFiles

  • Constructor Details

    • TestReplicationSource

      public TestReplicationSource()

  • Method Details

    • getCheckpointMetadata

      public abstract void getCheckpointMetadata(long replicationId, org.opensearch.indices.replication.checkpoint.ReplicationCheckpoint checkpoint, org.opensearch.core.action.ActionListener<org.opensearch.indices.replication.CheckpointInfoResponse> listener)
      Specified by:
      getCheckpointMetadata in interface org.opensearch.indices.replication.SegmentReplicationSource

    • getSegmentFiles

      public abstract void getSegmentFiles(long replicationId, org.opensearch.indices.replication.checkpoint.ReplicationCheckpoint checkpoint, List<org.opensearch.index.store.StoreFileMetadata> filesToFetch, org.opensearch.index.shard.IndexShard indexShard, BiConsumer<String,Long> fileProgressTracker, org.opensearch.core.action.ActionListener<org.opensearch.indices.replication.GetSegmentFilesResponse> listener)
      Specified by:
      getSegmentFiles in interface org.opensearch.indices.replication.SegmentReplicationSource

    • getDescription

      public String getDescription()
      Specified by:
      getDescription in interface org.opensearch.indices.replication.SegmentReplicationSource