Add disk usage info to nsfs metrics

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

missed committing config.js

Signed-off-by: Utkarsh Srivastava <srivastavautkarsh8097@gmail.com>

Author: tangledbytes

config.js

@@ -954,6 +954,11 @@ config.NSFS_GLACIER_FORCE_EXPIRE_ON_GET = false;
 // interval
 config.NSFS_GLACIER_MIGRATE_LOG_THRESHOLD = 50 * 1024;
 
+// NSFS_GLACIER_METRICS_STAT_PATH if set NooBaa will start reporting the statfs info of that
+// path as part of its metrics report
+config.NSFS_GLACIER_METRICS_STATFS_PATH = '';
+config.NSFS_GLACIER_METRICS_STATFS_INTERVAL = 60 * 1000; // Refresh statfs value every minute
+
 /** 
  * NSFS_GLACIER_RESERVED_BUCKET_TAGS defines an object of bucket tags which will be reserved
  * by the system and PUT operations for them via S3 API would be limited - as in they would be

src/server/analytic_services/prometheus_reporting.js

@@ -13,6 +13,8 @@ const stats_aggregator = require('../system_services/stats_aggregator');
 const AggregatorRegistry = require('prom-client').AggregatorRegistry;
 const aggregatorRegistry = new AggregatorRegistry();
 const http_utils = require('../../util/http_utils');
+const nb_native = require('../../util/nb_native');
+const { get_process_fs_context } = require('../../util/native_fs_utils');
 
 // Currenty supported reprots
 const reports = Object.seal({
@@ -48,6 +50,16 @@ async function export_all_metrics() {
     return all_metrics.join('\n\n');
 }
 
+/** @type {Record<string, number>} */
+let nsfs_metrics_statfs_path_cache = {};
+
+function get_disk_usage(statfs) {
+    if (!statfs || !statfs.blocks) return undefined;
+    if (statfs.blocks === 0) return undefined;
+    const ratio = (statfs.blocks - statfs.bfree) / statfs.blocks;
+    return Number(ratio?.toPrecision(2));
+}
+
 /**
  * Start Noobaa metrics server for http and https server
  * 
@@ -68,6 +80,21 @@ async function start_server(
     if (!config.PROMETHEUS_ENABLED) {
         return;
     }
+
+    if (config.NSFS_GLACIER_METRICS_STATFS_PATH) {
+        setInterval(async () => {
+            try {
+                nsfs_metrics_statfs_path_cache = await nb_native().fs.statfs(
+                    get_process_fs_context(),
+                    config.NSFS_GLACIER_METRICS_STATFS_PATH
+                );
+                dbg.log4('updated \'nsfs_metrics_statfs_path_cache\' with', nsfs_metrics_statfs_path_cache);
+            } catch (error) {
+                dbg.warn('failed to updated \'nsfs_metrics_statfs_path_cache\':', error);
+            }
+        }, config.NSFS_GLACIER_METRICS_STATFS_INTERVAL).unref();
+    }
+
     const metrics_request_handler = async (req, res) => {
         // Serve all metrics on the root path for system that do have one or more fork running.
         if (fork_enabled) {
@@ -77,7 +104,8 @@ async function start_server(
                 const nsfs_report = {
                     nsfs_counters: io_stats_complete,
                     op_stats_counters: ops_stats_complete,
-                    fs_worker_stats_counters: fs_worker_stats_complete
+                    fs_worker_stats_counters: fs_worker_stats_complete,
+                    disk_usage: get_disk_usage(nsfs_metrics_statfs_path_cache),
                 };
                 res.end(JSON.stringify(nsfs_report));
                 return;
@@ -209,7 +237,8 @@ async function metrics_nsfs_stats_handler() {
     const nsfs_report = {
         nsfs_counters: nsfs_io_stats,
         op_stats_counters: op_stats_counters,
-        fs_worker_stats_counters: fs_worker_stats_counters
+        fs_worker_stats_counters: fs_worker_stats_counters,
+        disk_usage: get_disk_usage(nsfs_metrics_statfs_path_cache),
     };
     dbg.log1('_create_nsfs_report: nsfs_report', nsfs_report);
     return JSON.stringify(nsfs_report);