Class OpenSearchIndexLevelReplicationTestCase.ReplicationGroup

java.lang.Object
org.opensearch.index.replication.OpenSearchIndexLevelReplicationTestCase.ReplicationGroup
All Implemented Interfaces:
AutoCloseable, Iterable<org.opensearch.index.shard.IndexShard>
Enclosing class:
OpenSearchIndexLevelReplicationTestCase
protected class OpenSearchIndexLevelReplicationTestCase.ReplicationGroup extends Object implements AutoCloseable, Iterable<org.opensearch.index.shard.IndexShard>

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    ReplicationGroup(org.opensearch.cluster.metadata.IndexMetadata indexMetadata)
     
    protected
    ReplicationGroup(org.opensearch.cluster.metadata.IndexMetadata indexMetadata, Path remotePath)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.opensearch.index.shard.IndexShard
    addReplica()
     
    org.opensearch.index.shard.IndexShard
    addReplica(Path remotePath)
     
    void
    addReplica(org.opensearch.index.shard.IndexShard replica)
     
    org.opensearch.index.shard.IndexShard
    addReplicaWithExistingPath(org.opensearch.index.shard.ShardPath shardPath, String nodeId)
     
    org.opensearch.index.seqno.RetentionLease
    addRetentionLease(String id, long retainingSequenceNumber, String source, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)
     
    int
    appendDocs(int numOfDoc)
     
    void
    assertAllEqual(int expectedCount)
     
    Future<Void>
    asyncRecoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier)
     
    void
    close()
     
    org.opensearch.action.bulk.BulkItemResponse
    delete(org.opensearch.action.delete.DeleteRequest deleteRequest)
     
    void
    executeRetentionLeasesSyncRequestOnReplica(org.opensearch.index.seqno.RetentionLeaseSyncAction.Request request, org.opensearch.index.shard.IndexShard replica)
     
    void
    flush()
     
    org.opensearch.cluster.node.DiscoveryNodes
    generateFakeDiscoveryNodes()
     
    protected org.opensearch.index.engine.EngineConfigFactory
    getEngineConfigFactory(org.opensearch.index.IndexSettings indexSettings)
     
    protected org.opensearch.index.engine.EngineFactory
    getEngineFactory(org.opensearch.cluster.routing.ShardRouting routing)
     
    org.opensearch.cluster.metadata.IndexMetadata
    getIndexMetadata()
     
    org.opensearch.index.shard.IndexShard
    getPrimary()
     
    org.opensearch.cluster.node.DiscoveryNode
    getPrimaryNode()
     
    List<org.opensearch.index.shard.IndexShard>
    getReplicas()
     
    org.opensearch.action.bulk.BulkItemResponse
    index(org.opensearch.action.index.IndexRequest indexRequest)
     
    int
    indexDocs(int numOfDoc)
     
    Iterator<org.opensearch.index.shard.IndexShard>
    iterator()
     
    Future<org.opensearch.index.shard.PrimaryReplicaSyncer.ResyncTask>
    promoteReplicaToPrimary(org.opensearch.index.shard.IndexShard replica)
    promotes the specific replica as the new primary
    void
    promoteReplicaToPrimary(org.opensearch.index.shard.IndexShard replica, BiConsumer<org.opensearch.index.shard.IndexShard, org.opensearch.core.action.ActionListener<org.opensearch.index.shard.PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer)
     
    protected void
    recoverPrimary(org.opensearch.index.shard.IndexShard primary)
     
    void
    recoverReplica(org.opensearch.index.shard.IndexShard replica)
     
    void
    recoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier)
     
    void
    recoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier, boolean markAsRecovering)
     
    void
    refresh(String source)
     
    void
    reinitPrimaryShard(Path remotePath)
     
    boolean
    removeReplica(org.opensearch.index.shard.IndexShard replica)
     
    void
    removeRetentionLease(String id, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)
     
    org.opensearch.index.seqno.RetentionLease
    renewRetentionLease(String id, long retainingSequenceNumber, String source)
     
    List<org.opensearch.cluster.routing.ShardRouting>
    shardRoutings()
     
    void
    startAll()
     
    void
    startPrimary()
     
    int
    startReplicas(int numOfReplicasToStart)
     
    void
    syncGlobalCheckpoint()
     
    protected void
    syncRetentionLeases(org.opensearch.core.index.shard.ShardId shardId, org.opensearch.index.seqno.RetentionLeases leases, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.lang.Iterable

    forEach, spliterator

  • Constructor Details

    • ReplicationGroup

      protected ReplicationGroup(org.opensearch.cluster.metadata.IndexMetadata indexMetadata) throws IOException
      Throws:
      IOException

    • ReplicationGroup

      protected ReplicationGroup(org.opensearch.cluster.metadata.IndexMetadata indexMetadata, Path remotePath) throws IOException
      Throws:
      IOException

  • Method Details

    • getEngineFactory

      protected org.opensearch.index.engine.EngineFactory getEngineFactory(org.opensearch.cluster.routing.ShardRouting routing)

    • getEngineConfigFactory

      protected org.opensearch.index.engine.EngineConfigFactory getEngineConfigFactory(org.opensearch.index.IndexSettings indexSettings)

    • getIndexMetadata

      public org.opensearch.cluster.metadata.IndexMetadata getIndexMetadata()

    • indexDocs

      public int indexDocs(int numOfDoc) throws Exception
      Throws:
      Exception

    • appendDocs

      public int appendDocs(int numOfDoc) throws Exception
      Throws:
      Exception

    • index

      public org.opensearch.action.bulk.BulkItemResponse index(org.opensearch.action.index.IndexRequest indexRequest) throws Exception
      Throws:
      Exception

    • delete

      public org.opensearch.action.bulk.BulkItemResponse delete(org.opensearch.action.delete.DeleteRequest deleteRequest) throws Exception
      Throws:
      Exception

    • startAll

      public void startAll() throws IOException
      Throws:
      IOException

    • generateFakeDiscoveryNodes

      public org.opensearch.cluster.node.DiscoveryNodes generateFakeDiscoveryNodes()

    • startReplicas

      public int startReplicas(int numOfReplicasToStart) throws IOException
      Throws:
      IOException

    • startPrimary

      public void startPrimary() throws IOException
      Throws:
      IOException

    • addReplica

      public org.opensearch.index.shard.IndexShard addReplica() throws IOException
      Throws:
      IOException

    • addReplica

      public org.opensearch.index.shard.IndexShard addReplica(Path remotePath) throws IOException
      Throws:
      IOException

    • addReplica

      public void addReplica(org.opensearch.index.shard.IndexShard replica) throws IOException
      Throws:
      IOException

    • recoverPrimary

      protected void recoverPrimary(org.opensearch.index.shard.IndexShard primary)

    • addReplicaWithExistingPath

      public org.opensearch.index.shard.IndexShard addReplicaWithExistingPath(org.opensearch.index.shard.ShardPath shardPath, String nodeId) throws IOException
      Throws:
      IOException

    • getReplicas

      public List<org.opensearch.index.shard.IndexShard> getReplicas()

    • promoteReplicaToPrimary

      public Future<org.opensearch.index.shard.PrimaryReplicaSyncer.ResyncTask> promoteReplicaToPrimary(org.opensearch.index.shard.IndexShard replica) throws IOException
      promotes the specific replica as the new primary
      Throws:
      IOException

    • promoteReplicaToPrimary

      public void promoteReplicaToPrimary(org.opensearch.index.shard.IndexShard replica, BiConsumer<org.opensearch.index.shard.IndexShard, org.opensearch.core.action.ActionListener<org.opensearch.index.shard.PrimaryReplicaSyncer.ResyncTask>> primaryReplicaSyncer) throws IOException
      Throws:
      IOException

    • removeReplica

      public boolean removeReplica(org.opensearch.index.shard.IndexShard replica) throws IOException
      Throws:
      IOException

    • recoverReplica

      public void recoverReplica(org.opensearch.index.shard.IndexShard replica) throws IOException
      Throws:
      IOException

    • recoverReplica

      public void recoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier) throws IOException
      Throws:
      IOException

    • recoverReplica

      public void recoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier, boolean markAsRecovering) throws IOException
      Throws:
      IOException

    • getPrimaryNode

      public org.opensearch.cluster.node.DiscoveryNode getPrimaryNode()

    • asyncRecoverReplica

      public Future<Void> asyncRecoverReplica(org.opensearch.index.shard.IndexShard replica, BiFunction<org.opensearch.index.shard.IndexShard, org.opensearch.cluster.node.DiscoveryNode, org.opensearch.indices.recovery.RecoveryTarget> targetSupplier)

    • assertAllEqual

      public void assertAllEqual(int expectedCount) throws IOException
      Throws:
      IOException

    • refresh

      public void refresh(String source)

    • flush

      public void flush()

    • shardRoutings

      public List<org.opensearch.cluster.routing.ShardRouting> shardRoutings()

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception

    • iterator

      public Iterator<org.opensearch.index.shard.IndexShard> iterator()
      Specified by:
      iterator in interface Iterable<org.opensearch.index.shard.IndexShard>

    • getPrimary

      public org.opensearch.index.shard.IndexShard getPrimary()

    • reinitPrimaryShard

      public void reinitPrimaryShard(Path remotePath) throws IOException
      Throws:
      IOException

    • syncGlobalCheckpoint

      public void syncGlobalCheckpoint()

    • syncRetentionLeases

      protected void syncRetentionLeases(org.opensearch.core.index.shard.ShardId shardId, org.opensearch.index.seqno.RetentionLeases leases, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)

    • addRetentionLease

      public org.opensearch.index.seqno.RetentionLease addRetentionLease(String id, long retainingSequenceNumber, String source, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)

    • renewRetentionLease

      public org.opensearch.index.seqno.RetentionLease renewRetentionLease(String id, long retainingSequenceNumber, String source)

    • removeRetentionLease

      public void removeRetentionLease(String id, org.opensearch.core.action.ActionListener<org.opensearch.action.support.replication.ReplicationResponse> listener)

    • executeRetentionLeasesSyncRequestOnReplica

      public void executeRetentionLeasesSyncRequestOnReplica(org.opensearch.index.seqno.RetentionLeaseSyncAction.Request request, org.opensearch.index.shard.IndexShard replica)