Skip to content

Commit bfe92a7

Browse files
committed
Refactor for upstream changes from PR import 9082
Signed-off-by: monusingh-1 <msnghgw@amazon.com>
1 parent 7385ade commit bfe92a7

39 files changed

+48
-48
lines changed

src/main/kotlin/org/opensearch/replication/ReplicationPlugin.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ import org.opensearch.replication.task.shard.ShardReplicationParams
7373
import org.opensearch.replication.task.shard.ShardReplicationState
7474
import org.opensearch.replication.util.Injectables
7575
import org.opensearch.action.ActionRequest
76-
import org.opensearch.action.ActionResponse
76+
import org.opensearch.core.action.ActionResponse
7777
import org.opensearch.client.Client
7878
import org.opensearch.cluster.NamedDiff
7979
import org.opensearch.cluster.metadata.IndexNameExpressionResolver

src/main/kotlin/org/opensearch/replication/action/autofollow/TransportAutoFollowClusterManagerNodeAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ import org.apache.logging.log4j.LogManager
2828
import org.opensearch.OpenSearchException
2929
import org.opensearch.ResourceAlreadyExistsException
3030
import org.opensearch.ResourceNotFoundException
31-
import org.opensearch.action.ActionListener
31+
import org.opensearch.core.action.ActionListener
3232
import org.opensearch.action.support.ActionFilters
3333
import org.opensearch.action.support.master.AcknowledgedResponse
3434
import org.opensearch.action.support.master.TransportMasterNodeAction

src/main/kotlin/org/opensearch/replication/action/autofollow/TransportUpdateAutoFollowPatternAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ import kotlinx.coroutines.CoroutineScope
2424
import kotlinx.coroutines.GlobalScope
2525
import kotlinx.coroutines.launch
2626
import org.apache.logging.log4j.LogManager
27-
import org.opensearch.action.ActionListener
27+
import org.opensearch.core.action.ActionListener
2828
import org.opensearch.action.support.ActionFilters
2929
import org.opensearch.action.support.HandledTransportAction
3030
import org.opensearch.action.support.master.AcknowledgedResponse

src/main/kotlin/org/opensearch/replication/action/changes/GetChangesResponse.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111

1212
package org.opensearch.replication.action.changes
1313

14-
import org.opensearch.action.ActionResponse
14+
import org.opensearch.core.action.ActionResponse
1515
import org.opensearch.core.common.io.stream.StreamInput
1616
import org.opensearch.core.common.io.stream.StreamOutput
1717
import org.opensearch.index.translog.Translog

src/main/kotlin/org/opensearch/replication/action/changes/TransportGetChangesAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import kotlinx.coroutines.GlobalScope
1515
import kotlinx.coroutines.launch
1616
import org.apache.logging.log4j.LogManager
1717
import org.opensearch.OpenSearchTimeoutException
18-
import org.opensearch.action.ActionListener
18+
import org.opensearch.core.action.ActionListener
1919
import org.opensearch.action.support.ActionFilters
2020
import org.opensearch.action.support.single.shard.TransportSingleShardAction
2121
import org.opensearch.cluster.ClusterState

src/main/kotlin/org/opensearch/replication/action/index/TransportReplicateIndexAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import kotlinx.coroutines.CoroutineScope
2626
import kotlinx.coroutines.GlobalScope
2727
import kotlinx.coroutines.launch
2828
import org.apache.logging.log4j.LogManager
29-
import org.opensearch.action.ActionListener
29+
import org.opensearch.core.action.ActionListener
3030
import org.opensearch.action.admin.indices.settings.get.GetSettingsRequest
3131
import org.opensearch.action.support.ActionFilters
3232
import org.opensearch.action.support.HandledTransportAction

src/main/kotlin/org/opensearch/replication/action/index/TransportReplicateIndexClusterManagerNodeAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ import kotlinx.coroutines.GlobalScope
2727
import kotlinx.coroutines.launch
2828
import org.apache.logging.log4j.LogManager
2929
import org.opensearch.OpenSearchStatusException
30-
import org.opensearch.action.ActionListener
30+
import org.opensearch.core.action.ActionListener
3131
import org.opensearch.action.support.ActionFilters
3232
import org.opensearch.action.support.IndicesOptions
3333
import org.opensearch.action.support.master.AcknowledgedResponse

src/main/kotlin/org/opensearch/replication/action/index/block/TransportUpddateIndexBlockAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import kotlinx.coroutines.GlobalScope
2020
import kotlinx.coroutines.launch
2121
import org.apache.logging.log4j.LogManager
2222
import org.opensearch.OpenSearchException
23-
import org.opensearch.action.ActionListener
23+
import org.opensearch.core.action.ActionListener
2424
import org.opensearch.action.support.ActionFilters
2525
import org.opensearch.action.support.master.AcknowledgedResponse
2626
import org.opensearch.action.support.master.TransportMasterNodeAction

src/main/kotlin/org/opensearch/replication/action/pause/TransportPauseIndexReplicationAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import kotlinx.coroutines.launch
2222
import org.apache.logging.log4j.LogManager
2323
import org.opensearch.OpenSearchException
2424
import org.opensearch.ResourceAlreadyExistsException
25-
import org.opensearch.action.ActionListener
25+
import org.opensearch.core.action.ActionListener
2626
import org.opensearch.action.support.ActionFilters
2727
import org.opensearch.action.support.master.AcknowledgedRequest
2828
import org.opensearch.action.support.master.AcknowledgedResponse

src/main/kotlin/org/opensearch/replication/action/replay/TransportReplayChangesAction.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import kotlinx.coroutines.SupervisorJob
2525
import kotlinx.coroutines.asCoroutineDispatcher
2626
import kotlinx.coroutines.launch
2727
import org.apache.logging.log4j.LogManager
28-
import org.opensearch.action.ActionListener
28+
import org.opensearch.core.action.ActionListener
2929
import org.opensearch.action.admin.indices.mapping.get.GetMappingsRequest
3030
import org.opensearch.action.admin.indices.mapping.put.PutMappingRequest
3131
import org.opensearch.action.index.IndexRequest

0 commit comments

Comments
 (0)