ShadowySpirits commented on code in PR #5875:
URL: https://github.com/apache/rocketmq/pull/5875#discussion_r1070213777
##########
tieredstore/src/main/java/org/apache/rocketmq/store/tiered/common/TieredMessageStoreConfig.java:
##########
@@ -17,9 +17,126 @@
package org.apache.rocketmq.store.tiered.common;
import java.io.File;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
public class TieredMessageStoreConfig {
+ private String brokerName = localHostName();
+ private String brokerClusterName = "DefaultCluster";
+ private TieredStorageLevel tieredStorageLevel =
TieredStorageLevel.NOT_IN_DISK;
+ public enum TieredStorageLevel {
+ DISABLE(0),
+ NOT_IN_DISK(1),
+ NOT_IN_MEM(2),
+ FORCE(3);
+
+ private final int value;
+
+ TieredStorageLevel(int value) {
+ this.value = value;
+ }
+
+ public int getValue() {
+ return value;
+ }
+
+ public static TieredStorageLevel valueOf(int value) {
+ switch (value) {
+ case 1:
+ return NOT_IN_DISK;
+ case 2:
+ return NOT_IN_MEM;
+ case 3:
+ return FORCE;
+ default:
+ return DISABLE;
+ }
+ }
+
+ public boolean isEnable() {
+ return this.value > 0;
+ }
+
+ public boolean check(TieredStorageLevel targetLevel) {
+ return this.value >= targetLevel.value;
+ }
+ }
+
private String storePathRootDir = System.getProperty("user.home") +
File.separator + "store";
+ private boolean messageIndexEnable = true;
+
+ // CommitLog file size, default is 1G
+ private long tieredStoreCommitLogMaxSize = 1024 * 1024 * 1024;
+ // ConsumeQueue file size, default is 100M
+ private long tieredStoreConsumeQueueMaxSize = 100 * 1024 * 1024;
+ private int tieredStoreIndexFileMaxHashSlotNum = 5000000;
+ private int tieredStoreIndexFileMaxIndexNum = 5000000 * 4;
+ // index file will force rolling to next file after idle specified time,
default is 3h
+ private int tieredStoreIndexFileRollingIdleInterval = 3 * 60 * 60 * 1000;
+ private String tieredMetadataServiceProvider =
"org.apache.rocketmq.store.tiered.metadata.TieredMetadataManager";
+ private String tieredBackendServiceProvider = "";
+ // file reserved time, default is 72 hour
+ private int tieredStoreFileReservedTime = 72;
Review Comment:
I meant to keep the samilar name with fileReservedTime in brokerConfig.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
