Implementing reload in encrypted blob store

Signed-off-by: vikasvb90 <[email protected]>
opensearch-project · Mar 21, 2024 · 8e81a2c · 8e81a2c
1 parent 90a815e
commit 8e81a2c
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/server/src/main/java/org/opensearch/common/blobstore/EncryptedBlobStore.java b/server/src/main/java/org/opensearch/common/blobstore/EncryptedBlobStore.java
@@ -9,6 +9,7 @@
 package org.opensearch.common.blobstore;
 
 import org.opensearch.cluster.metadata.CryptoMetadata;
+import org.opensearch.cluster.metadata.RepositoryMetadata;
 import org.opensearch.common.crypto.CryptoHandler;
 import org.opensearch.crypto.CryptoHandlerRegistry;
 import org.opensearch.crypto.CryptoRegistryException;
@@ -65,6 +66,15 @@ public BlobContainer blobContainer(BlobPath path) {
         return new EncryptedBlobContainer<>(blobContainer, cryptoHandler);
     }
 
+    /**
+     * Reoload blobstore metadata
+     * @param repositoryMetadata new repository metadata
+     */
+    @Override
+    public void reload(RepositoryMetadata repositoryMetadata) {
+        blobStore.reload(repositoryMetadata);
+    }
+
     /**
      * Retrieves statistics about the BlobStore. Delegates the call to the underlying BlobStore's stats() method.
      *