Set repo prefix to remote_store in RemotePublicationConfigurationIT.

Signed-off-by: Swetha Guptha <[email protected]>
SwethaGuptha · Oct 22, 2024 · fdfb6ee · fdfb6ee
1 parent 49b45cc
commit fdfb6ee
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...ernalClusterTest/java/org/opensearch/gateway/remote/RemotePublicationConfigurationIT.java b/...ernalClusterTest/java/org/opensearch/gateway/remote/RemotePublicationConfigurationIT.java
@@ -66,7 +66,7 @@ public void setUp() throws Exception {
     }
 
     public Settings.Builder remotePublishConfiguredNodeSetting() {
-        String remoteStoreNodeAttributePrefix = "remote_publication";
+        String remoteStoreNodeAttributePrefix = "remote_store";
         String stateRepoSettingsAttributeKeyPrefix = String.format(
             Locale.getDefault(),
             "node.attr." + REPOSITORY_SETTINGS_ATTRIBUTE_KEY_PREFIX,
@@ -83,21 +83,23 @@ public Settings.Builder remotePublishConfiguredNodeSetting() {
         String routingTableRepoTypeAttributeKey = String.format(
             Locale.getDefault(),
             "node.attr." + REPOSITORY_TYPE_ATTRIBUTE_KEY_FORMAT,
+            remoteStoreNodeAttributePrefix,
             ROUTING_TABLE_REPO_NAME
         );
         String routingTableRepoSettingsAttributeKeyPrefix = String.format(
             Locale.getDefault(),
             "node.attr." + REPOSITORY_SETTINGS_ATTRIBUTE_KEY_PREFIX,
+            remoteStoreNodeAttributePrefix,
             ROUTING_TABLE_REPO_NAME
         );
 
         Settings.Builder builder = Settings.builder()
-            .put("node.attr." + "remote_publication.state.repository", REPOSITORY_NAME)
+            .put("node.attr." + "remote_store.state.repository", REPOSITORY_NAME)
             .put(stateRepoTypeAttributeKey, ReloadableFsRepository.TYPE)
             .put(stateRepoSettingsAttributeKeyPrefix + "location", segmentRepoPath)
             .put(stateRepoSettingsAttributeKeyPrefix + prefixModeVerificationSuffix, true)
             .put(REMOTE_CLUSTER_STATE_ENABLED_SETTING.getKey(), true)
-            .put("node.attr." + "remote_publication.routing_table.repository", ROUTING_TABLE_REPO_NAME)
+            .put("node.attr." + "remote_store.routing_table.repository", ROUTING_TABLE_REPO_NAME)
             .put(routingTableRepoTypeAttributeKey, ReloadableFsRepository.TYPE)
             .put(routingTableRepoSettingsAttributeKeyPrefix + "location", segmentRepoPath);
         return builder;