[Rename] refactor o.e.transport in the server module. (#284)

Refactor the transport package in the server module to rename the package from `org.elasticsearch.transport` to `org.opensearch.transport`

Signed-off-by: Rabi Panda <adnapibar@gmail.com>

client/client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/action/bulk/TransportNoopBulkAction.java

@@ -30,7 +30,7 @@ import org.elasticsearch.action.update.UpdateResponse;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 public class TransportNoopBulkAction extends HandledTransportAction<BulkRequest, BulkResponse> {
     private static final BulkItemResponse ITEM_RESPONSE = new BulkItemResponse(1, DocWriteRequest.OpType.UPDATE,

client/client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/action/search/TransportNoopSearchAction.java

@@ -34,7 +34,7 @@ import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.profile.SearchProfileShardResults;
 import org.elasticsearch.search.suggest.Suggest;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.Collections;
 

client/rest-high-level/src/test/java/org/elasticsearch/client/BulkProcessorRetryIT.java

@@ -29,7 +29,7 @@ import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.xcontent.XContentType;
 import org.opensearch.rest.RestStatus;
-import org.elasticsearch.transport.RemoteTransportException;
+import org.opensearch.transport.RemoteTransportException;
 
 import java.util.Collections;
 import java.util.Iterator;

client/rest-high-level/src/test/java/org/elasticsearch/client/ClusterClientIT.java

@@ -53,8 +53,8 @@ import org.elasticsearch.common.xcontent.XContentType;
 import org.elasticsearch.common.xcontent.support.XContentMapValues;
 import org.elasticsearch.indices.recovery.RecoverySettings;
 import org.opensearch.rest.RestStatus;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.SniffConnectionStrategy;
+import org.opensearch.transport.SniffConnectionStrategy;
 
 import java.io.IOException;
 import java.util.Collections;

client/rest-high-level/src/test/java/org/elasticsearch/client/cluster/RemoteInfoResponseTests.java

@@ -23,9 +23,9 @@ import org.elasticsearch.client.AbstractResponseTestCase;
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.xcontent.XContentParser;
 import org.elasticsearch.common.xcontent.XContentType;
-import org.elasticsearch.transport.ProxyConnectionStrategy;
+import org.opensearch.transport.ProxyConnectionStrategy;
-import org.elasticsearch.transport.RemoteConnectionInfo;
+import org.opensearch.transport.RemoteConnectionInfo;
-import org.elasticsearch.transport.SniffConnectionStrategy;
+import org.opensearch.transport.SniffConnectionStrategy;
 
 import java.io.IOException;
 import java.util.ArrayList;

client/rest-high-level/src/test/java/org/elasticsearch/client/indices/CloseIndexResponseTests.java

@@ -32,7 +32,7 @@ import org.elasticsearch.common.xcontent.XContentType;
 import org.elasticsearch.index.Index;
 import org.elasticsearch.index.IndexNotFoundException;
 import org.opensearch.rest.RestStatus;
-import org.elasticsearch.transport.ActionNotFoundTransportException;
+import org.opensearch.transport.ActionNotFoundTransportException;
 
 import java.io.IOException;
 import java.util.ArrayList;

modules/ingest-common/src/main/java/org/opensearch/ingest/common/GrokProcessorGetAction.java

@@ -37,7 +37,7 @@ import org.opensearch.rest.BaseRestHandler;
 import org.opensearch.rest.RestRequest;
 import org.opensearch.rest.action.RestToXContentListener;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.List;

modules/ingest-common/src/test/java/org/opensearch/ingest/common/GrokProcessorGetActionTests.java

@@ -29,7 +29,7 @@ import org.elasticsearch.common.xcontent.XContentBuilder;
 import org.elasticsearch.common.xcontent.XContentHelper;
 import org.elasticsearch.common.xcontent.json.JsonXContent;
 import org.elasticsearch.test.ESTestCase;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Collections;

modules/lang-mustache/src/main/java/org/opensearch/script/mustache/TransportMultiSearchTemplateAction.java

@@ -30,7 +30,7 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.xcontent.NamedXContentRegistry;
 import org.opensearch.script.ScriptService;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.List;

modules/lang-mustache/src/main/java/org/opensearch/script/mustache/TransportSearchTemplateAction.java

@@ -40,7 +40,7 @@ import org.opensearch.script.TemplateScript;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.search.internal.SearchContext;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Collections;

modules/lang-painless/src/main/java/org/opensearch/painless/action/PainlessContextAction.java

@@ -41,7 +41,7 @@ import org.opensearch.rest.RestRequest;
 import org.opensearch.rest.action.RestToXContentListener;
 import org.opensearch.script.ScriptContext;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

modules/lang-painless/src/main/java/org/opensearch/painless/action/PainlessExecuteAction.java

@@ -79,7 +79,7 @@ import org.opensearch.script.ScriptContext;
 import org.opensearch.script.ScriptService;
 import org.opensearch.script.ScriptType;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Collections;

modules/rank-eval/src/main/java/org/opensearch/index/rankeval/TransportRankEvalAction.java

@@ -40,7 +40,7 @@ import org.opensearch.script.TemplateScript;
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

modules/rank-eval/src/test/java/org/opensearch/index/rankeval/TransportRankEvalActionTests.java

@@ -32,7 +32,7 @@ import org.elasticsearch.env.Environment;
 import org.opensearch.script.ScriptService;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.test.ESTestCase;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

modules/reindex/src/main/java/org/opensearch/index/reindex/TransportDeleteByQueryAction.java

@@ -34,7 +34,7 @@ import org.elasticsearch.index.reindex.DeleteByQueryRequest;
 import org.opensearch.script.ScriptService;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 
 public class TransportDeleteByQueryAction extends HandledTransportAction<DeleteByQueryRequest, BulkByScrollResponse> {

modules/reindex/src/main/java/org/opensearch/index/reindex/TransportReindexAction.java

@@ -39,7 +39,7 @@ import org.elasticsearch.index.reindex.ReindexRequest;
 import org.opensearch.script.ScriptService;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.List;
 import java.util.function.Function;

modules/reindex/src/main/java/org/opensearch/index/reindex/TransportRethrottleAction.java

@@ -34,7 +34,7 @@ import org.elasticsearch.index.reindex.LeaderBulkByScrollTaskState;
 import org.elasticsearch.tasks.TaskId;
 import org.elasticsearch.tasks.TaskInfo;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.List;
 

modules/reindex/src/main/java/org/opensearch/index/reindex/TransportUpdateByQueryAction.java

@@ -45,7 +45,7 @@ import org.opensearch.script.Script;
 import org.opensearch.script.ScriptService;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.Map;
 import java.util.function.BiFunction;

modules/reindex/src/test/java/org/opensearch/index/reindex/UpdateByQueryWithScriptTests.java

@@ -24,7 +24,7 @@ import org.opensearch.cluster.ClusterState;
 import org.elasticsearch.index.reindex.BulkByScrollResponse;
 import org.elasticsearch.index.reindex.UpdateByQueryRequest;
 import org.opensearch.script.ScriptService;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.Collections;
 import java.util.Date;

modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/Netty4TransportMultiPortIntegrationIT.java

@@ -33,9 +33,9 @@ import org.elasticsearch.env.Environment;
 import org.elasticsearch.test.ESIntegTestCase.ClusterScope;
 import org.elasticsearch.test.ESIntegTestCase.Scope;
 import org.elasticsearch.test.junit.annotations.Network;
-import org.elasticsearch.transport.MockTransportClient;
+import org.opensearch.transport.MockTransportClient;
 import org.opensearch.transport.Netty4Plugin;
-import org.elasticsearch.transport.TransportInfo;
+import org.opensearch.transport.TransportInfo;
 
 import java.net.InetAddress;
 import java.util.Arrays;

modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/Netty4TransportPublishAddressIT.java

@@ -29,7 +29,7 @@ import org.elasticsearch.common.transport.BoundTransportAddress;
 import org.elasticsearch.common.transport.TransportAddress;
 import org.elasticsearch.test.ESIntegTestCase;
 import org.opensearch.transport.Netty4Plugin;
-import org.elasticsearch.transport.TransportInfo;
+import org.opensearch.transport.TransportInfo;
 
 import java.net.Inet4Address;
 

modules/transport-netty4/src/internalClusterTest/java/org/opensearch/transport/netty4/OpenSearchLoggingHandlerIT.java

@@ -28,8 +28,8 @@ import org.elasticsearch.test.ESIntegTestCase;
 import org.elasticsearch.test.InternalTestCluster;
 import org.elasticsearch.test.MockLogAppender;
 import org.elasticsearch.test.junit.annotations.TestLogging;
-import org.elasticsearch.transport.TcpTransport;
+import org.opensearch.transport.TcpTransport;
-import org.elasticsearch.transport.TransportLogger;
+import org.opensearch.transport.TransportLogger;
 
 import java.io.IOException;
 

modules/transport-netty4/src/main/java/org/opensearch/transport/Netty4Plugin.java

@@ -33,10 +33,10 @@ import org.elasticsearch.common.xcontent.NamedXContentRegistry;
 import org.elasticsearch.http.HttpServerTransport;
 import org.opensearch.http.netty4.Netty4HttpServerTransport;
 import org.elasticsearch.indices.breaker.CircuitBreakerService;
-import org.elasticsearch.plugins.NetworkPlugin;
+import org.opensearch.plugins.NetworkPlugin;
-import org.elasticsearch.plugins.Plugin;
+import org.opensearch.plugins.Plugin;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 import org.opensearch.transport.netty4.Netty4Transport;
 
 import java.util.Arrays;

modules/transport-netty4/src/main/java/org/opensearch/transport/SharedGroupFactory.java

@@ -26,10 +26,8 @@ import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.util.concurrent.AbstractRefCounted;
-import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.elasticsearch.http.HttpServerTransport;
 import org.opensearch.http.netty4.Netty4HttpServerTransport;
-import org.elasticsearch.transport.TcpTransport;
 import org.opensearch.transport.netty4.Netty4Transport;
 
 import java.util.concurrent.TimeUnit;

modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4MessageChannelHandler.java

@@ -32,9 +32,9 @@ import org.elasticsearch.common.bytes.ReleasableBytesReference;
 import org.elasticsearch.common.lease.Releasables;
 import org.elasticsearch.common.util.PageCacheRecycler;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.InboundPipeline;
+import org.opensearch.transport.InboundPipeline;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.Transports;
+import org.opensearch.transport.Transports;
 
 import java.nio.channels.ClosedChannelException;
 import java.util.ArrayDeque;

modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4TcpChannel.java

@@ -27,8 +27,8 @@ import org.opensearch.action.ActionListener;
 import org.elasticsearch.common.Nullable;
 import org.elasticsearch.common.bytes.BytesReference;
 import org.elasticsearch.common.concurrent.CompletableContext;
-import org.elasticsearch.transport.TcpChannel;
+import org.opensearch.transport.TcpChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
 
 import java.net.InetSocketAddress;
 

modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4TcpServerChannel.java

@@ -22,7 +22,7 @@ package org.opensearch.transport.netty4;
 import io.netty.channel.Channel;
 import org.opensearch.action.ActionListener;
 import org.elasticsearch.common.concurrent.CompletableContext;
-import org.elasticsearch.transport.TcpServerChannel;
+import org.opensearch.transport.TcpServerChannel;
 
 import java.net.InetSocketAddress;
 

modules/transport-netty4/src/main/java/org/opensearch/transport/netty4/Netty4Transport.java

@@ -56,8 +56,8 @@ import org.opensearch.transport.Netty4NioSocketChannel;
 import org.opensearch.transport.NettyAllocator;
 import org.opensearch.transport.NettyByteBufSizer;
 import org.opensearch.transport.SharedGroupFactory;
-import org.elasticsearch.transport.TcpTransport;
+import org.opensearch.transport.TcpTransport;
-import org.elasticsearch.transport.TransportSettings;
+import org.opensearch.transport.TransportSettings;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;

modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/Netty4SizeHeaderFrameDecoderTests.java

@@ -31,7 +31,7 @@ import org.elasticsearch.mocksocket.MockSocket;
 import org.elasticsearch.test.ESTestCase;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.SharedGroupFactory;
-import org.elasticsearch.transport.TransportSettings;
+import org.opensearch.transport.TransportSettings;
 import org.junit.After;
 import org.junit.Before;
 

modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/NettyTransportMultiPortTests.java

@@ -31,8 +31,8 @@ import org.elasticsearch.test.ESTestCase;
 import org.opensearch.threadpool.TestThreadPool;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.transport.SharedGroupFactory;
-import org.elasticsearch.transport.TcpTransport;
+import org.opensearch.transport.TcpTransport;
-import org.elasticsearch.transport.TransportSettings;
+import org.opensearch.transport.TransportSettings;
 import org.junit.Before;
 
 import java.util.Collections;

modules/transport-netty4/src/test/java/org/opensearch/transport/netty4/SimpleNetty4TransportTests.java

@@ -34,15 +34,15 @@ import org.elasticsearch.core.internal.net.NetUtils;
 import org.elasticsearch.indices.breaker.NoneCircuitBreakerService;
 import org.elasticsearch.test.transport.MockTransportService;
 import org.elasticsearch.test.transport.StubbableTransport;
-import org.elasticsearch.transport.AbstractSimpleTransportTestCase;
+import org.opensearch.transport.AbstractSimpleTransportTestCase;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.ConnectionProfile;
+import org.opensearch.transport.ConnectionProfile;
 import org.opensearch.transport.Netty4NioSocketChannel;
 import org.opensearch.transport.SharedGroupFactory;
-import org.elasticsearch.transport.TcpChannel;
+import org.opensearch.transport.TcpChannel;
-import org.elasticsearch.transport.TcpTransport;
+import org.opensearch.transport.TcpTransport;
-import org.elasticsearch.transport.TestProfiles;
+import org.opensearch.transport.TestProfiles;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.io.IOException;
 import java.net.InetAddress;

server/src/main/java/org/elasticsearch/action/delete/TransportDeleteAction.java

@@ -23,7 +23,7 @@ import org.opensearch.action.bulk.TransportBulkAction;
 import org.opensearch.action.bulk.TransportSingleItemBulkWriteAction;
 import org.opensearch.action.support.ActionFilters;
 import org.elasticsearch.common.inject.Inject;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 /**
  * Performs the delete operation.

server/src/main/java/org/elasticsearch/action/explain/TransportExplainAction.java

@@ -50,7 +50,7 @@ import org.elasticsearch.search.rescore.RescoreContext;
 import org.elasticsearch.search.rescore.Rescorer;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Set;

server/src/main/java/org/elasticsearch/action/fieldcaps/TransportFieldCapabilitiesAction.java

@@ -32,9 +32,9 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.util.concurrent.CountDown;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.RemoteClusterAware;
+import org.opensearch.transport.RemoteClusterAware;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/action/fieldcaps/TransportFieldCapabilitiesIndexAction.java

@@ -55,11 +55,11 @@ import org.elasticsearch.search.internal.AliasFilter;
 import org.elasticsearch.search.internal.ShardSearchRequest;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Collections;

server/src/main/java/org/elasticsearch/action/get/TransportGetAction.java

@@ -35,7 +35,7 @@ import org.elasticsearch.index.shard.IndexShard;
 import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.indices.IndicesService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/get/TransportMultiGetAction.java

@@ -31,7 +31,7 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.util.concurrent.AtomicArray;
 import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.HashMap;
 import java.util.Map;

server/src/main/java/org/elasticsearch/action/get/TransportShardMultiGetAction.java

@@ -36,7 +36,7 @@ import org.elasticsearch.index.shard.IndexShard;
 import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.indices.IndicesService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/index/TransportIndexAction.java

@@ -23,7 +23,7 @@ import org.opensearch.action.bulk.TransportBulkAction;
 import org.opensearch.action.bulk.TransportSingleItemBulkWriteAction;
 import org.opensearch.action.support.ActionFilters;
 import org.elasticsearch.common.inject.Inject;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 /**
  * Performs the index operation.

server/src/main/java/org/elasticsearch/action/ingest/DeletePipelineTransportAction.java

@@ -31,7 +31,7 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.ingest.IngestService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/ingest/GetPipelineTransportAction.java

@@ -31,7 +31,7 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.ingest.IngestService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/ingest/IngestActionForwarder.java

@@ -27,7 +27,7 @@ import org.opensearch.cluster.ClusterChangedEvent;
 import org.opensearch.cluster.ClusterStateApplier;
 import org.opensearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.common.Randomness;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.concurrent.atomic.AtomicInteger;
 

server/src/main/java/org/elasticsearch/action/ingest/PutPipelineTransportAction.java

@@ -37,13 +37,13 @@ import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.ingest.IngestInfo;
 import org.elasticsearch.ingest.IngestService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
 
-import static org.elasticsearch.ingest.IngestService.INGEST_ORIGIN;
+import static org.opensearch.ingest.IngestService.INGEST_ORIGIN;
 
 public class PutPipelineTransportAction extends TransportMasterNodeAction<PutPipelineRequest, AcknowledgedResponse> {
 

server/src/main/java/org/elasticsearch/action/ingest/SimulatePipelineTransportAction.java

@@ -28,7 +28,7 @@ import org.elasticsearch.common.xcontent.XContentHelper;
 import org.elasticsearch.ingest.IngestService;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.Map;
 

server/src/main/java/org/elasticsearch/action/main/TransportMainAction.java

@@ -30,7 +30,7 @@ import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.node.Node;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 public class TransportMainAction extends HandledTransportAction<MainRequest, MainResponse> {
 

server/src/main/java/org/elasticsearch/action/resync/TransportResyncReplicationAction.java

@@ -43,9 +43,9 @@ import org.elasticsearch.indices.SystemIndices;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.threadpool.ThreadPool.Names;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.function.Function;

server/src/main/java/org/elasticsearch/action/search/AbstractSearchAsyncAction.java

@@ -44,7 +44,7 @@ import org.elasticsearch.search.internal.AliasFilter;
 import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.internal.SearchContext;
 import org.elasticsearch.search.internal.ShardSearchRequest;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.ArrayDeque;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/search/CanMatchPreFilterSearchPhase.java

@@ -31,7 +31,7 @@ import org.elasticsearch.search.internal.AliasFilter;
 import org.elasticsearch.search.sort.FieldSortBuilder;
 import org.elasticsearch.search.sort.MinAndMax;
 import org.elasticsearch.search.sort.SortOrder;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.Comparator;
 import java.util.List;

server/src/main/java/org/elasticsearch/action/search/ClearScrollController.java

@@ -27,8 +27,8 @@ import org.opensearch.cluster.node.DiscoveryNode;
 import org.opensearch.cluster.node.DiscoveryNodes;
 import org.elasticsearch.common.Strings;
 import org.elasticsearch.common.util.concurrent.CountDown;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
 
 import java.util.ArrayList;
 import java.util.Collection;

server/src/main/java/org/elasticsearch/action/search/DfsQueryPhase.java

@@ -25,7 +25,7 @@ import org.elasticsearch.search.dfs.AggregatedDfs;
 import org.elasticsearch.search.dfs.DfsSearchResult;
 import org.elasticsearch.search.query.QuerySearchRequest;
 import org.elasticsearch.search.query.QuerySearchResult;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.io.IOException;
 import java.util.List;

server/src/main/java/org/elasticsearch/action/search/FetchSearchPhase.java

@@ -35,7 +35,7 @@ import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.internal.ShardSearchContextId;
 import org.elasticsearch.search.internal.ShardSearchRequest;
 import org.elasticsearch.search.query.QuerySearchResult;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.List;
 import java.util.function.BiFunction;

server/src/main/java/org/elasticsearch/action/search/SearchContextId.java

@@ -32,7 +32,7 @@ import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.search.SearchPhaseResult;
 import org.elasticsearch.search.SearchShardTarget;
 import org.elasticsearch.search.internal.AliasFilter;
-import org.elasticsearch.transport.RemoteClusterAware;
+import org.opensearch.transport.RemoteClusterAware;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;

server/src/main/java/org/elasticsearch/action/search/SearchDfsQueryThenFetchAsyncAction.java

@@ -28,7 +28,7 @@ import org.elasticsearch.search.builder.SearchSourceBuilder;
 import org.elasticsearch.search.dfs.AggregatedDfs;
 import org.elasticsearch.search.dfs.DfsSearchResult;
 import org.elasticsearch.search.internal.AliasFilter;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.List;
 import java.util.Map;

server/src/main/java/org/elasticsearch/action/search/SearchExecutionStatsCollector.java

@@ -23,7 +23,7 @@ import org.opensearch.action.ActionListener;
 import org.elasticsearch.node.ResponseCollectorService;
 import org.elasticsearch.search.SearchPhaseResult;
 import org.elasticsearch.search.query.QuerySearchResult;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.Objects;
 import java.util.function.BiFunction;

server/src/main/java/org/elasticsearch/action/search/SearchPhaseContext.java

@@ -28,7 +28,7 @@ import org.elasticsearch.search.SearchShardTarget;
 import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.internal.ShardSearchContextId;
 import org.elasticsearch.search.internal.ShardSearchRequest;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.concurrent.Executor;
 
@@ -89,7 +89,7 @@ interface SearchPhaseContext extends Executor {
     void onShardFailure(int shardIndex, @Nullable SearchShardTarget shardTarget, Exception e);
 
     /**
-     * Returns a connection to the node if connected otherwise and {@link org.elasticsearch.transport.ConnectTransportException} will be
+     * Returns a connection to the node if connected otherwise and {@link org.opensearch.transport.ConnectTransportException} will be
      * thrown.
      */
     Transport.Connection getConnection(String clusterAlias, String nodeId);

server/src/main/java/org/elasticsearch/action/search/SearchQueryThenFetchAsyncAction.java

@@ -30,7 +30,7 @@ import org.elasticsearch.search.internal.AliasFilter;
 import org.elasticsearch.search.internal.SearchContext;
 import org.elasticsearch.search.internal.ShardSearchRequest;
 import org.elasticsearch.search.query.QuerySearchResult;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.Map;
 import java.util.Set;

server/src/main/java/org/elasticsearch/action/search/SearchScrollAsyncAction.java

@@ -32,8 +32,8 @@ import org.elasticsearch.search.SearchShardTarget;
 import org.elasticsearch.search.internal.InternalScrollSearchRequest;
 import org.elasticsearch.search.internal.InternalSearchResponse;
 import org.elasticsearch.search.internal.ShardSearchContextId;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/search/SearchScrollQueryAndFetchAsyncAction.java

@@ -27,7 +27,7 @@ import org.elasticsearch.common.util.concurrent.AtomicArray;
 import org.elasticsearch.search.fetch.QueryFetchSearchResult;
 import org.elasticsearch.search.fetch.ScrollQueryFetchSearchResult;
 import org.elasticsearch.search.internal.InternalScrollSearchRequest;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.function.BiFunction;
 

server/src/main/java/org/elasticsearch/action/search/SearchScrollQueryThenFetchAsyncAction.java

@@ -33,7 +33,7 @@ import org.elasticsearch.search.fetch.ShardFetchRequest;
 import org.elasticsearch.search.internal.InternalScrollSearchRequest;
 import org.elasticsearch.search.query.QuerySearchResult;
 import org.elasticsearch.search.query.ScrollQuerySearchResult;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
 
 import java.util.function.BiFunction;
 

server/src/main/java/org/elasticsearch/action/search/SearchTransportService.java

@@ -47,14 +47,14 @@ import org.elasticsearch.search.query.QuerySearchRequest;
 import org.elasticsearch.search.query.QuerySearchResult;
 import org.elasticsearch.search.query.ScrollQuerySearchResult;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.TransportActionProxy;
+import org.opensearch.transport.TransportActionProxy;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.HashMap;

server/src/main/java/org/elasticsearch/action/search/ShardSearchFailure.java

@@ -34,7 +34,7 @@ import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.rest.RestStatus;
 import org.elasticsearch.search.SearchException;
 import org.elasticsearch.search.SearchShardTarget;
-import org.elasticsearch.transport.RemoteClusterAware;
+import org.opensearch.transport.RemoteClusterAware;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/search/TransportClearScrollAction.java

@@ -26,7 +26,7 @@ import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 public class TransportClearScrollAction extends HandledTransportAction<ClearScrollRequest, ClearScrollResponse> {
 

server/src/main/java/org/elasticsearch/action/search/TransportMultiSearchAction.java

@@ -33,7 +33,7 @@ import org.elasticsearch.common.util.concurrent.AtomicArray;
 import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;

server/src/main/java/org/elasticsearch/action/search/TransportSearchAction.java

@@ -71,11 +71,11 @@ import org.elasticsearch.search.profile.SearchProfileShardResults;
 import org.opensearch.tasks.Task;
 import org.opensearch.tasks.TaskId;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.RemoteClusterAware;
+import org.opensearch.transport.RemoteClusterAware;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.RemoteTransportException;
+import org.opensearch.transport.RemoteTransportException;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/action/search/TransportSearchHelper.java

@@ -27,7 +27,7 @@ import org.elasticsearch.search.SearchPhaseResult;
 import org.elasticsearch.search.SearchShardTarget;
 import org.elasticsearch.search.internal.InternalScrollSearchRequest;
 import org.elasticsearch.search.internal.ShardSearchContextId;
-import org.elasticsearch.transport.RemoteClusterAware;
+import org.opensearch.transport.RemoteClusterAware;
 
 import java.io.IOException;
 import java.io.UncheckedIOException;

server/src/main/java/org/elasticsearch/action/search/TransportSearchScrollAction.java

@@ -26,7 +26,7 @@ import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import static org.elasticsearch.action.search.ParsedScrollId.QUERY_AND_FETCH_TYPE;
 import static org.elasticsearch.action.search.ParsedScrollId.QUERY_THEN_FETCH_TYPE;

server/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastShardRequest.java

@@ -25,7 +25,7 @@ import org.opensearch.action.support.IndicesOptions;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/broadcast/BroadcastShardResponse.java

@@ -22,7 +22,7 @@ package org.elasticsearch.action.support.broadcast;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.index.shard.ShardId;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/broadcast/TransportBroadcastAction.java

@@ -40,11 +40,11 @@ import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.concurrent.atomic.AtomicInteger;

server/src/main/java/org/elasticsearch/action/support/broadcast/node/TransportBroadcastByNodeAction.java

@@ -45,14 +45,14 @@ import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.NodeShouldNotConnectException;
+import org.opensearch.transport.NodeShouldNotConnectException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/support/master/TransportMasterNodeAction.java

@@ -45,10 +45,10 @@ import org.elasticsearch.discovery.MasterNotDiscoveredException;
 import org.elasticsearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.RemoteTransportException;
+import org.opensearch.transport.RemoteTransportException;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.function.Predicate;

server/src/main/java/org/elasticsearch/action/support/master/TransportMasterNodeReadAction.java

@@ -25,7 +25,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 /**
  * A base class for read operations that needs to be performed on the master node.

server/src/main/java/org/elasticsearch/action/support/master/info/TransportClusterInfoAction.java

@@ -29,7 +29,7 @@ import org.opensearch.cluster.metadata.IndexNameExpressionResolver;
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 public abstract class TransportClusterInfoAction<Request extends ClusterInfoRequest<Request>, Response extends ActionResponse>
         extends TransportMasterNodeReadAction<Request, Response> {

server/src/main/java/org/elasticsearch/action/support/nodes/BaseNodeRequest.java

@@ -22,7 +22,7 @@ package org.elasticsearch.action.support.nodes;
 import org.opensearch.Version;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/nodes/BaseNodeResponse.java

@@ -22,7 +22,7 @@ package org.elasticsearch.action.support.nodes;
 import org.opensearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/nodes/TransportNodesAction.java

@@ -32,14 +32,14 @@ import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.Writeable;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.NodeShouldNotConnectException;
+import org.opensearch.transport.NodeShouldNotConnectException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/support/replication/ReplicationOperation.java

@@ -43,7 +43,7 @@ import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.node.NodeClosedException;
 import org.opensearch.rest.RestStatus;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/support/replication/TransportBroadcastReplicationAction.java

@@ -38,7 +38,7 @@ import org.elasticsearch.common.io.stream.Writeable;
 import org.elasticsearch.common.util.concurrent.CountDown;
 import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java

@@ -71,13 +71,13 @@ import org.elasticsearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.tasks.TaskId;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Map;

server/src/main/java/org/elasticsearch/action/support/replication/TransportWriteAction.java

@@ -46,7 +46,7 @@ import org.elasticsearch.index.translog.Translog.Location;
 import org.elasticsearch.indices.IndicesService;
 import org.elasticsearch.indices.SystemIndices;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;

server/src/main/java/org/elasticsearch/action/support/single/instance/TransportInstanceSingleOperationAction.java

@@ -44,13 +44,13 @@ import org.elasticsearch.node.NodeClosedException;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.threadpool.ThreadPool.Names;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/single/shard/TransportSingleShardAction.java

@@ -44,11 +44,11 @@ import org.elasticsearch.common.logging.LoggerMessageFormat;
 import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/support/tasks/TransportTasksAction.java

@@ -39,15 +39,15 @@ import org.elasticsearch.common.io.stream.Writeable;
 import org.elasticsearch.common.util.concurrent.AtomicArray;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.NodeShouldNotConnectException;
+import org.opensearch.transport.NodeShouldNotConnectException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/action/termvectors/TransportMultiTermVectorsAction.java

@@ -32,7 +32,7 @@ import org.elasticsearch.common.util.concurrent.AtomicArray;
 import org.elasticsearch.index.IndexNotFoundException;
 import org.elasticsearch.index.shard.ShardId;
 import org.opensearch.tasks.Task;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.HashMap;
 import java.util.Map;

server/src/main/java/org/elasticsearch/action/termvectors/TransportShardMultiTermsVectorAction.java

@@ -35,7 +35,7 @@ import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.index.termvectors.TermVectorsService;
 import org.elasticsearch.indices.IndicesService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 public class TransportShardMultiTermsVectorAction extends
         TransportSingleShardAction<MultiTermVectorsShardRequest, MultiTermVectorsShardResponse> {

server/src/main/java/org/elasticsearch/action/termvectors/TransportTermVectorsAction.java

@@ -36,7 +36,7 @@ import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.index.termvectors.TermVectorsService;
 import org.elasticsearch.indices.IndicesService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 

server/src/main/java/org/elasticsearch/action/update/TransportUpdateAction.java

@@ -58,7 +58,7 @@ import org.elasticsearch.indices.IndicesService;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
 import org.opensearch.threadpool.ThreadPool.Names;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Collections;

server/src/main/java/org/elasticsearch/bootstrap/Security.java

@@ -28,7 +28,7 @@ import org.elasticsearch.http.HttpTransportSettings;
 import org.elasticsearch.plugins.PluginInfo;
 import org.elasticsearch.plugins.PluginsService;
 import org.opensearch.secure_sm.SecureSM;
-import org.elasticsearch.transport.TcpTransport;
+import org.opensearch.transport.TcpTransport;
 
 import java.io.IOException;
 import java.net.SocketPermission;

server/src/main/java/org/elasticsearch/common/network/NetworkModule.java

@@ -45,10 +45,10 @@ import org.elasticsearch.plugins.NetworkPlugin;
 import org.opensearch.tasks.RawTaskStatus;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.TransportInterceptor;
+import org.opensearch.transport.TransportInterceptor;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/common/settings/ClusterSettings.java

@@ -119,11 +119,11 @@ import org.elasticsearch.search.fetch.subphase.highlight.FastVectorHighlighter;
 import org.opensearch.snapshots.InternalSnapshotsInfoService;
 import org.opensearch.snapshots.SnapshotsService;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.ProxyConnectionStrategy;
+import org.opensearch.transport.ProxyConnectionStrategy;
-import org.elasticsearch.transport.RemoteClusterService;
+import org.opensearch.transport.RemoteClusterService;
-import org.elasticsearch.transport.RemoteConnectionStrategy;
+import org.opensearch.transport.RemoteConnectionStrategy;
-import org.elasticsearch.transport.SniffConnectionStrategy;
+import org.opensearch.transport.SniffConnectionStrategy;
-import org.elasticsearch.transport.TransportSettings;
+import org.opensearch.transport.TransportSettings;
 import org.elasticsearch.watcher.ResourceWatcherService;
 
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/common/util/concurrent/BaseFuture.java

@@ -23,7 +23,7 @@ import org.elasticsearch.cluster.service.ClusterApplierService;
 import org.elasticsearch.cluster.service.MasterService;
 import org.elasticsearch.common.Nullable;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.Transports;
+import org.opensearch.transport.Transports;
 
 import java.util.Objects;
 import java.util.concurrent.CancellationException;

server/src/main/java/org/elasticsearch/discovery/DiscoveryModule.java

@@ -43,7 +43,7 @@ import org.elasticsearch.gateway.GatewayMetaState;
 import org.elasticsearch.monitor.NodeHealthService;
 import org.elasticsearch.plugins.DiscoveryPlugin;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.nio.file.Path;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/discovery/HandshakingTransportAddressConnector.java

@@ -35,11 +35,11 @@ import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.concurrent.AbstractRunnable;
 import org.elasticsearch.core.internal.io.IOUtils;
 import org.elasticsearch.discovery.PeerFinder.TransportAddressConnector;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.ConnectionProfile;
+import org.opensearch.transport.ConnectionProfile;
-import org.elasticsearch.transport.Transport.Connection;
+import org.opensearch.transport.Transport.Connection;
-import org.elasticsearch.transport.TransportRequestOptions.Type;
+import org.opensearch.transport.TransportRequestOptions.Type;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import static java.util.Collections.emptyMap;
 import static java.util.Collections.emptySet;

server/src/main/java/org/elasticsearch/discovery/PeerFinder.java

@@ -43,13 +43,13 @@ import org.elasticsearch.discovery.zen.ZenPing;
 import org.elasticsearch.discovery.zen.ZenPing.PingResponse;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool.Names;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.ArrayList;

server/src/main/java/org/elasticsearch/discovery/PeersRequest.java

@@ -22,7 +22,7 @@ package org.elasticsearch.discovery;
 import org.opensearch.cluster.node.DiscoveryNode;
 import org.elasticsearch.common.io.stream.StreamInput;
 import org.elasticsearch.common.io.stream.StreamOutput;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
 
 import java.io.IOException;
 import java.util.List;

server/src/main/java/org/elasticsearch/discovery/SeedHostsResolver.java

@@ -32,7 +32,7 @@ import org.elasticsearch.common.util.concurrent.AbstractRunnable;
 import org.elasticsearch.common.util.concurrent.EsExecutors;
 import org.elasticsearch.discovery.PeerFinder.ConfiguredHostsResolver;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.ArrayList;
 import java.util.Arrays;

server/src/main/java/org/elasticsearch/discovery/SettingsBasedSeedHostsProvider.java

@@ -25,7 +25,7 @@ import org.elasticsearch.common.settings.Setting;
 import org.elasticsearch.common.settings.Setting.Property;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.transport.TransportAddress;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.util.List;
 import java.util.function.Function;

server/src/main/java/org/elasticsearch/discovery/zen/FaultDetection.java

@@ -31,9 +31,9 @@ import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.concurrent.AbstractRunnable;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.Transport;
+import org.opensearch.transport.Transport;
-import org.elasticsearch.transport.TransportConnectionListener;
+import org.opensearch.transport.TransportConnectionListener;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import static org.elasticsearch.common.unit.TimeValue.timeValueSeconds;
 
@@ -92,7 +92,7 @@ public abstract class FaultDetection implements Closeable {
     }
 
     /**
-     * This method will be called when the {@link org.elasticsearch.transport.TransportService} raised a node disconnected event
+     * This method will be called when the {@link org.opensearch.transport.TransportService} raised a node disconnected event
      */
     abstract void handleTransportDisconnect(DiscoveryNode node);
 

server/src/main/java/org/elasticsearch/discovery/zen/MasterFaultDetection.java

@@ -38,15 +38,15 @@ import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.ConnectTransportException;
+import org.opensearch.transport.ConnectTransportException;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportException;
+import org.opensearch.transport.TransportException;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportRequestOptions;
+import org.opensearch.transport.TransportRequestOptions;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
-import org.elasticsearch.transport.TransportResponseHandler;
+import org.opensearch.transport.TransportResponseHandler;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.concurrent.CopyOnWriteArrayList;

server/src/main/java/org/elasticsearch/discovery/zen/MembershipAction.java

@@ -29,12 +29,12 @@ import org.elasticsearch.common.io.stream.StreamOutput;
 import org.elasticsearch.common.unit.TimeValue;
 import org.opensearch.tasks.Task;
 import org.opensearch.threadpool.ThreadPool;
-import org.elasticsearch.transport.EmptyTransportResponseHandler;
+import org.opensearch.transport.EmptyTransportResponseHandler;
-import org.elasticsearch.transport.TransportChannel;
+import org.opensearch.transport.TransportChannel;
-import org.elasticsearch.transport.TransportRequest;
+import org.opensearch.transport.TransportRequest;
-import org.elasticsearch.transport.TransportRequestHandler;
+import org.opensearch.transport.TransportRequestHandler;
-import org.elasticsearch.transport.TransportResponse;
+import org.opensearch.transport.TransportResponse;
-import org.elasticsearch.transport.TransportService;
+import org.opensearch.transport.TransportService;
 
 import java.io.IOException;
 import java.util.Collection;