Add OFF level (#11530)

* Add OFF

* Fix comment

Author: SpriCoder

iotdb-core/confignode/src/assembly/resources/conf/iotdb-confignode.properties

@@ -125,7 +125,7 @@ cn_seed_config_node=127.0.0.1:10710
 # cn_metric_reporter_list=
 
 # The level of metric module
-# Options: [CORE, IMPORTANT, NORMAL, ALL]
+# Options: [OFF, CORE, IMPORTANT, NORMAL, ALL]
 # Datatype: String
 # cn_metric_level=CORE
 

iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties

@@ -261,7 +261,7 @@ dn_seed_config_node=127.0.0.1:10710
 # dn_metric_reporter_list=
 
 # The level of metric module
-# Options: [CORE, IMPORTANT, NORMAL, ALL]
+# Options: [OFF, CORE, IMPORTANT, NORMAL, ALL]
 # Datatype: String
 # dn_metric_level=CORE
 

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DoNothingDiskMetricsManager.java

@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.iotdb.metrics.metricsets.disk;
+
+public class DoNothingDiskMetricsManager implements IDiskMetricsManager {}

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/IDiskMetricsManager.java

@@ -19,6 +19,9 @@
 
 package org.apache.iotdb.metrics.metricsets.disk;
 
+import org.apache.iotdb.metrics.config.MetricConfigDescriptor;
+import org.apache.iotdb.metrics.utils.MetricLevel;
+
 import java.util.Collections;
 import java.util.Map;
 import java.util.Set;
@@ -110,14 +113,21 @@ default Set<String> getDiskIds() {
 
   /** Return different implementation of DiskMetricsManager according to OS type. */
   static IDiskMetricsManager getDiskMetricsManager() {
-    String os = System.getProperty("os.name").toLowerCase();
-
-    if (os.startsWith("windows")) {
-      return new WindowsDiskMetricsManager();
-    } else if (os.startsWith("linux")) {
-      return new LinuxDiskMetricsManager();
+    if (MetricConfigDescriptor.getInstance()
+        .getMetricConfig()
+        .getMetricLevel()
+        .equals(MetricLevel.OFF)) {
+      return new DoNothingDiskMetricsManager();
     } else {
-      return new MacDiskMetricsManager();
+      String os = System.getProperty("os.name").toLowerCase();
+
+      if (os.startsWith("windows")) {
+        return new WindowsDiskMetricsManager();
+      } else if (os.startsWith("linux")) {
+        return new LinuxDiskMetricsManager();
+      } else {
+        return new MacDiskMetricsManager();
+      }
     }
   }
 }

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/DoNothingNetMetricManager.java

@@ -0,0 +1,22 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.iotdb.metrics.metricsets.net;
+
+public class DoNothingNetMetricManager implements INetMetricManager {}

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/INetMetricManager.java

@@ -19,22 +19,14 @@
 
 package org.apache.iotdb.metrics.metricsets.net;
 
+import org.apache.iotdb.metrics.config.MetricConfigDescriptor;
+import org.apache.iotdb.metrics.utils.MetricLevel;
+
 import java.util.Collections;
 import java.util.Map;
 import java.util.Set;
 
 public interface INetMetricManager {
-  static INetMetricManager getNetMetricManager() {
-    String os = System.getProperty("os.name").toLowerCase();
-
-    if (os.startsWith("windows")) {
-      return new WindowsNetMetricManager();
-    } else if (os.startsWith("linux")) {
-      return new LinuxNetMetricManager();
-    } else {
-      return new MacNetMetricManager();
-    }
-  }
 
   default Map<String, Long> getReceivedByte() {
     return Collections.emptyMap();
@@ -59,4 +51,23 @@ default Set<String> getIfaceSet() {
   default int getConnectionNum() {
     return 0;
   }
+
+  static INetMetricManager getNetMetricManager() {
+    if (MetricConfigDescriptor.getInstance()
+        .getMetricConfig()
+        .getMetricLevel()
+        .equals(MetricLevel.OFF)) {
+      return new DoNothingNetMetricManager();
+    } else {
+      String os = System.getProperty("os.name").toLowerCase();
+
+      if (os.startsWith("windows")) {
+        return new WindowsNetMetricManager();
+      } else if (os.startsWith("linux")) {
+        return new LinuxNetMetricManager();
+      } else {
+        return new MacNetMetricManager();
+      }
+    }
+  }
 }

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/system/SystemMetrics.java

@@ -20,6 +20,7 @@
 package org.apache.iotdb.metrics.metricsets.system;
 
 import org.apache.iotdb.metrics.AbstractMetricService;
+import org.apache.iotdb.metrics.config.MetricConfigDescriptor;
 import org.apache.iotdb.metrics.metricsets.IMetricSet;
 import org.apache.iotdb.metrics.utils.MetricLevel;
 import org.apache.iotdb.metrics.utils.MetricType;
@@ -57,26 +58,31 @@ public SystemMetrics() {
   }
 
   public void setDiskDirs(List<String> diskDirs) {
-    this.diskDirs.set(diskDirs);
-    for (String diskDir : this.diskDirs.get()) {
-      if (!FSUtils.isLocal(diskDir)) {
-        continue;
-      }
-      Path path = Paths.get(diskDir);
-      FileStore fileStore = null;
-      try {
-        fileStore = Files.getFileStore(path);
-      } catch (IOException e) {
-        // check parent if path is not exists
-        path = path.getParent();
+    if (!MetricConfigDescriptor.getInstance()
+        .getMetricConfig()
+        .getMetricLevel()
+        .equals(MetricLevel.OFF)) {
+      this.diskDirs.set(diskDirs);
+      for (String diskDir : this.diskDirs.get()) {
+        if (!FSUtils.isLocal(diskDir)) {
+          continue;
+        }
+        Path path = Paths.get(diskDir);
+        FileStore fileStore = null;
         try {
           fileStore = Files.getFileStore(path);
-        } catch (IOException innerException) {
-          logger.error("Failed to get storage path of {}, because", diskDir, innerException);
+        } catch (IOException e) {
+          // check parent if path is not exists
+          path = path.getParent();
+          try {
+            fileStore = Files.getFileStore(path);
+          } catch (IOException innerException) {
+            logger.error("Failed to get storage path of {}, because", diskDir, innerException);
+          }
+        }
+        if (null != fileStore) {
+          fileStores.add(fileStore);
         }
-      }
-      if (null != fileStore) {
-        fileStores.add(fileStore);
       }
     }
   }

iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricLevel.java

@@ -24,7 +24,7 @@ public enum MetricLevel {
   NORMAL(1),
   IMPORTANT(2),
   CORE(3),
-  DO_NOTHING(4);
+  OFF(4);
 
   /** Level of metric service. */
   final int level;