feat: expose node config to StoreMetadataService

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
AutoMQ · Oct 24, 2023 · 565dde3 · 565dde3
1 parent 99dd8c3
commit 565dde3
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/metadata/src/main/java/com/automq/rocketmq/metadata/DefaultStoreMetadataService.java b/metadata/src/main/java/com/automq/rocketmq/metadata/DefaultStoreMetadataService.java
@@ -22,6 +22,7 @@
 import apache.rocketmq.controller.v1.S3WALObject;
 import apache.rocketmq.controller.v1.StreamMetadata;
 import apache.rocketmq.controller.v1.StreamRole;
+import com.automq.rocketmq.common.config.ControllerConfig;
 import com.automq.rocketmq.controller.exception.ControllerException;
 import com.automq.rocketmq.controller.metadata.MetadataStore;
 import com.automq.rocketmq.controller.metadata.database.DefaultMetadataStore;
@@ -146,6 +147,11 @@ public int ownerNode(long topicId, int queueId) {
         return metadataStore.ownerNode(topicId, queueId);
     }
 
+    @Override
+    public ControllerConfig nodeConfig() {
+        return metadataStore.config();
+    }
+
     @Override
     public CompletableFuture<List<StreamMetadata>> getStreams(List<Long> streamIds) {
         return metadataStore.getStreams(streamIds);

diff --git a/metadata/src/main/java/com/automq/rocketmq/metadata/api/StoreMetadataService.java b/metadata/src/main/java/com/automq/rocketmq/metadata/api/StoreMetadataService.java
@@ -20,6 +20,7 @@
 import apache.rocketmq.controller.v1.S3StreamObject;
 import apache.rocketmq.controller.v1.S3WALObject;
 import apache.rocketmq.controller.v1.StreamMetadata;
+import com.automq.rocketmq.common.config.ControllerConfig;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import org.apache.commons.lang3.tuple.Pair;
@@ -184,6 +185,8 @@ CompletableFuture<Pair<List<S3StreamObject>, List<S3WALObject>>> listObjects(lon
 
     int ownerNode(long topicId, int queueId);
 
+    ControllerConfig nodeConfig();
+
     /**
      * Get the stream metadata for the specified list of stream ids.
      * @param streamIds list of specified stream ids

diff --git a/store/src/test/java/com/automq/rocketmq/store/mock/MockStoreMetadataService.java b/store/src/test/java/com/automq/rocketmq/store/mock/MockStoreMetadataService.java
@@ -20,6 +20,7 @@
 import apache.rocketmq.controller.v1.S3StreamObject;
 import apache.rocketmq.controller.v1.S3WALObject;
 import apache.rocketmq.controller.v1.StreamMetadata;
+import com.automq.rocketmq.common.config.ControllerConfig;
 import com.automq.rocketmq.metadata.api.StoreMetadataService;
 import java.nio.ByteBuffer;
 import java.util.List;
@@ -142,6 +143,11 @@ public int ownerNode(long topicId, int queueId) {
         return 0;
     }
 
+    @Override
+    public ControllerConfig nodeConfig() {
+        return null;
+    }
+
     @Override
     public CompletableFuture<List<StreamMetadata>> getStreams(List<Long> streamIds) {
         return null;