move package common under replication

Signed-off-by: Poojita Raj <poojiraj@amazon.com>

server/src/internalClusterTest/java/org/opensearch/gateway/RecoveryFromGatewayIT.java

@@ -62,7 +62,7 @@
 import org.opensearch.index.shard.ShardPath;
 import org.opensearch.indices.IndicesService;
 import org.opensearch.indices.recovery.RecoveryState;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.plugins.Plugin;
 import org.opensearch.test.OpenSearchIntegTestCase;
 import org.opensearch.test.OpenSearchIntegTestCase.ClusterScope;

server/src/internalClusterTest/java/org/opensearch/indices/recovery/IndexRecoveryIT.java

@@ -101,7 +101,7 @@
 import org.opensearch.indices.IndicesService;
 import org.opensearch.indices.NodeIndicesStats;
 import org.opensearch.indices.analysis.AnalysisModule;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.indices.recovery.RecoveryState.Stage;
 import org.opensearch.node.NodeClosedException;
 import org.opensearch.node.RecoverySettingsChunkSizePlugin;

server/src/main/java/org/opensearch/cluster/metadata/IndexMetadata.java

@@ -70,7 +70,7 @@
 import org.opensearch.index.mapper.MapperService;
 import org.opensearch.index.seqno.SequenceNumbers;
 import org.opensearch.index.shard.ShardId;
-import org.opensearch.indices.common.ReplicationType;
+import org.opensearch.indices.replication.common.ReplicationType;
 import org.opensearch.rest.RestStatus;
 
 import java.io.IOException;

server/src/main/java/org/opensearch/index/IndexSettings.java

@@ -46,7 +46,7 @@
 import org.opensearch.common.unit.ByteSizeValue;
 import org.opensearch.common.unit.TimeValue;
 import org.opensearch.index.translog.Translog;
-import org.opensearch.indices.common.ReplicationType;
+import org.opensearch.indices.replication.common.ReplicationType;
 import org.opensearch.ingest.IngestService;
 import org.opensearch.node.Node;
 

server/src/main/java/org/opensearch/index/shard/StoreRecovery.java

@@ -62,7 +62,7 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.index.translog.Translog;
 import org.opensearch.indices.recovery.RecoveryState;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.repositories.IndexId;
 import org.opensearch.repositories.Repository;
 

server/src/main/java/org/opensearch/indices/cluster/IndicesClusterStateService.java

@@ -80,7 +80,7 @@
 import org.opensearch.indices.recovery.PeerRecoveryTargetService;
 import org.opensearch.indices.recovery.RecoveryListener;
 import org.opensearch.indices.recovery.RecoveryState;
-import org.opensearch.indices.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ShardTargetState;
 import org.opensearch.repositories.RepositoriesService;
 import org.opensearch.search.SearchService;
 import org.opensearch.snapshots.SnapshotShardsService;

server/src/main/java/org/opensearch/indices/recovery/MultiFileWriter.java

@@ -44,7 +44,7 @@
 import org.opensearch.common.util.concurrent.ConcurrentCollections;
 import org.opensearch.index.store.Store;
 import org.opensearch.index.store.StoreFileMetadata;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.transport.Transports;
 
 import java.io.IOException;

server/src/main/java/org/opensearch/indices/recovery/PeerRecoveryTargetService.java

@@ -69,10 +69,10 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.index.translog.Translog;
 import org.opensearch.index.translog.TranslogCorruptedException;
-import org.opensearch.indices.common.ShardTargetCollection;
-import org.opensearch.indices.common.ShardTargetCollection.ShardTargetRef;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
-import org.opensearch.indices.common.ReplicationTimer;
+import org.opensearch.indices.replication.common.ShardTargetCollection;
+import org.opensearch.indices.replication.common.ShardTargetCollection.ShardTargetRef;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationTimer;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.ConnectTransportException;

server/src/main/java/org/opensearch/indices/recovery/RecoveryListener.java

@@ -11,8 +11,8 @@
 import org.opensearch.OpenSearchException;
 import org.opensearch.cluster.routing.ShardRouting;
 import org.opensearch.indices.cluster.IndicesClusterStateService;
-import org.opensearch.indices.common.ShardTargetListener;
-import org.opensearch.indices.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetState;
 
 /**
  * Listener that runs on changes in Recovery state

server/src/main/java/org/opensearch/indices/recovery/RecoveryState.java

@@ -45,9 +45,9 @@
 import org.opensearch.common.xcontent.XContentBuilder;
 import org.opensearch.index.shard.IndexShard;
 import org.opensearch.index.shard.ShardId;
-import org.opensearch.indices.common.ShardTargetState;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
-import org.opensearch.indices.common.ReplicationTimer;
+import org.opensearch.indices.replication.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationTimer;
 
 import java.io.IOException;
 import java.util.Locale;

server/src/main/java/org/opensearch/indices/recovery/RecoveryTarget.java

@@ -55,10 +55,10 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.index.store.StoreFileMetadata;
 import org.opensearch.index.translog.Translog;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
-import org.opensearch.indices.common.ShardTarget;
-import org.opensearch.indices.common.ShardTargetListener;
-import org.opensearch.indices.common.ShardTargetCollection;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ShardTarget;
+import org.opensearch.indices.replication.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetCollection;
 
 import java.io.IOException;
 import java.nio.file.Path;

server/src/main/java/org/opensearch/indices/common/ReplicationLuceneIndex.java → server/src/main/java/org/opensearch/indices/replication/common/ReplicationLuceneIndex.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.opensearch.common.Strings;
 import org.opensearch.common.io.stream.StreamInput;

server/src/main/java/org/opensearch/indices/common/ReplicationRequestTracker.java → server/src/main/java/org/opensearch/indices/replication/common/ReplicationRequestTracker.java

@@ -30,7 +30,7 @@
  * GitHub history for details.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.opensearch.action.ActionListener;
 import org.opensearch.common.Nullable;

server/src/main/java/org/opensearch/indices/common/ReplicationTimer.java → server/src/main/java/org/opensearch/indices/replication/common/ReplicationTimer.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.io.stream.StreamOutput;

server/src/main/java/org/opensearch/indices/common/ReplicationType.java → server/src/main/java/org/opensearch/indices/replication/common/ReplicationType.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 /**
  * Enumerates the types of replication strategies supported by OpenSearch.

server/src/main/java/org/opensearch/indices/common/ShardTarget.java → server/src/main/java/org/opensearch/indices/replication/common/ShardTarget.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.apache.logging.log4j.Logger;
 import org.opensearch.ExceptionsHelper;

server/src/main/java/org/opensearch/indices/common/ShardTargetCollection.java → server/src/main/java/org/opensearch/indices/replication/common/ShardTargetCollection.java

@@ -30,7 +30,7 @@
  * GitHub history for details.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.apache.logging.log4j.Logger;
 import org.apache.logging.log4j.message.ParameterizedMessage;

server/src/main/java/org/opensearch/indices/common/ShardTargetListener.java → server/src/main/java/org/opensearch/indices/replication/common/ShardTargetListener.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 import org.opensearch.OpenSearchException;
 

server/src/main/java/org/opensearch/indices/common/ShardTargetState.java → server/src/main/java/org/opensearch/indices/replication/common/ShardTargetState.java

@@ -6,7 +6,7 @@
  * compatible open source license.
  */
 
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;
 
 /**
  * Represents a state object used to track copying of segments from an external source

server/src/main/java/org/opensearch/indices/common/package-info.java → server/src/main/java/org/opensearch/indices/replication/common/package-info.java

@@ -7,4 +7,4 @@
  */
 
 /** Foundation classes for Replication Implementation. */
-package org.opensearch.indices.common;
+package org.opensearch.indices.replication.common;

server/src/test/java/org/opensearch/index/replication/RecoveryDuringReplicationTests.java

@@ -71,7 +71,7 @@
 import org.opensearch.index.translog.Translog;
 import org.opensearch.indices.recovery.RecoveryState;
 import org.opensearch.indices.recovery.RecoveryTarget;
-import org.opensearch.indices.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetListener;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/test/java/org/opensearch/index/shard/IndexShardTests.java

@@ -133,7 +133,7 @@
 import org.opensearch.indices.fielddata.cache.IndicesFieldDataCache;
 import org.opensearch.indices.recovery.RecoveryState;
 import org.opensearch.indices.recovery.RecoveryTarget;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.repositories.IndexId;
 import org.opensearch.snapshots.Snapshot;
 import org.opensearch.snapshots.SnapshotId;

server/src/test/java/org/opensearch/index/shard/StoreRecoveryTests.java

@@ -61,7 +61,7 @@
 import org.opensearch.index.mapper.IdFieldMapper;
 import org.opensearch.index.mapper.Uid;
 import org.opensearch.index.seqno.SequenceNumbers;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.test.OpenSearchTestCase;
 
 import java.io.IOException;

server/src/test/java/org/opensearch/indices/recovery/RecoverySourceHandlerTests.java

@@ -94,7 +94,7 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.index.store.StoreFileMetadata;
 import org.opensearch.index.translog.Translog;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.test.CorruptionUtils;
 import org.opensearch.test.DummyShardLock;
 import org.opensearch.test.IndexSettingsModule;

server/src/test/java/org/opensearch/indices/recovery/RecoveryTargetTests.java

@@ -41,12 +41,12 @@
 import org.opensearch.common.io.stream.StreamInput;
 import org.opensearch.common.io.stream.Writeable;
 import org.opensearch.index.shard.ShardId;
-import org.opensearch.indices.common.ReplicationLuceneIndex.FileMetadata;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex.FileMetadata;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.indices.recovery.RecoveryState.Stage;
 import org.opensearch.indices.recovery.RecoveryState.Translog;
 import org.opensearch.indices.recovery.RecoveryState.VerifyIndex;
-import org.opensearch.indices.common.ReplicationTimer;
+import org.opensearch.indices.replication.common.ReplicationTimer;
 import org.opensearch.test.OpenSearchTestCase;
 
 import java.io.IOException;

server/src/test/java/org/opensearch/indices/recovery/RecoveryTests.java

@@ -69,8 +69,8 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.index.translog.SnapshotMatchers;
 import org.opensearch.index.translog.Translog;
-import org.opensearch.indices.common.ShardTargetListener;
-import org.opensearch.indices.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetState;
 
 import java.io.IOException;
 import java.util.HashMap;

server/src/test/java/org/opensearch/indices/recovery/ReplicationRequestTrackerTests.java

@@ -36,7 +36,7 @@
 import org.opensearch.action.ActionListener;
 import org.opensearch.action.support.PlainActionFuture;
 import org.opensearch.common.util.concurrent.ConcurrentCollections;
-import org.opensearch.indices.common.ReplicationRequestTracker;
+import org.opensearch.indices.replication.common.ReplicationRequestTracker;
 import org.opensearch.test.OpenSearchTestCase;
 import org.opensearch.threadpool.TestThreadPool;
 

server/src/test/java/org/opensearch/recovery/RecoveriesCollectionTests.java

@@ -38,9 +38,9 @@
 import org.opensearch.index.shard.IndexShard;
 import org.opensearch.index.shard.ShardId;
 import org.opensearch.index.store.Store;
-import org.opensearch.indices.common.ShardTargetCollection;
-import org.opensearch.indices.common.ShardTargetListener;
-import org.opensearch.indices.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ShardTargetCollection;
+import org.opensearch.indices.replication.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetState;
 import org.opensearch.indices.recovery.RecoveryState;
 import org.opensearch.indices.recovery.RecoveryTarget;
 

server/src/test/java/org/opensearch/repositories/fs/FsRepositoryTests.java

@@ -68,7 +68,7 @@
 import org.opensearch.index.store.Store;
 import org.opensearch.indices.recovery.RecoverySettings;
 import org.opensearch.indices.recovery.RecoveryState;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
 import org.opensearch.repositories.IndexId;
 import org.opensearch.repositories.blobstore.BlobStoreTestUtil;
 import org.opensearch.snapshots.Snapshot;

server/src/test/java/org/opensearch/rest/action/cat/RestRecoveryActionTests.java

@@ -45,8 +45,8 @@
 import org.opensearch.index.Index;
 import org.opensearch.index.shard.ShardId;
 import org.opensearch.indices.recovery.RecoveryState;
-import org.opensearch.indices.common.ReplicationLuceneIndex;
-import org.opensearch.indices.common.ReplicationTimer;
+import org.opensearch.indices.replication.common.ReplicationLuceneIndex;
+import org.opensearch.indices.replication.common.ReplicationTimer;
 import org.opensearch.test.OpenSearchTestCase;
 
 import java.util.ArrayList;

test/framework/src/main/java/org/opensearch/index/shard/IndexShardTestCase.java

@@ -94,8 +94,8 @@
 import org.opensearch.indices.recovery.RecoveryState;
 import org.opensearch.indices.recovery.RecoveryTarget;
 import org.opensearch.indices.recovery.StartRecoveryRequest;
-import org.opensearch.indices.common.ShardTargetListener;
-import org.opensearch.indices.common.ShardTargetState;
+import org.opensearch.indices.replication.common.ShardTargetListener;
+import org.opensearch.indices.replication.common.ShardTargetState;
 import org.opensearch.repositories.IndexId;
 import org.opensearch.repositories.Repository;
 import org.opensearch.repositories.blobstore.OpenSearchBlobStoreRepositoryIntegTestCase;