in_node_exporter_metrics: add Linux sockstat collector

Signed-off-by: Eduardo Silva <[email protected]>

Author: edsiper

plugins/in_node_exporter_metrics/CMakeLists.txt

@@ -7,6 +7,7 @@ set(src
   ne_stat.c
   ne_vmstat.c
   ne_netdev.c
+  ne_sockstat.c
   ne_time.c
   ne_loadavg.c
   ne_filefd.c

plugins/in_node_exporter_metrics/ne.c

@@ -39,6 +39,7 @@
 #include "ne_loadavg.h"
 #include "ne_vmstat.h"
 #include "ne_netdev.h"
+#include "ne_sockstat.h"
 #include "ne_textfile.h"
 #include "ne_systemd.h"
 #include "ne_processes.h"
@@ -192,6 +193,7 @@ static int in_ne_init(struct flb_input_instance *in,
     mk_list_add(&loadavg_collector._head, &ctx->collectors);
     mk_list_add(&vmstat_collector._head, &ctx->collectors);
     mk_list_add(&netdev_collector._head, &ctx->collectors);
+    mk_list_add(&sockstat_collector._head, &ctx->collectors);
     mk_list_add(&filefd_collector._head, &ctx->collectors);
     mk_list_add(&textfile_collector._head, &ctx->collectors);
     mk_list_add(&systemd_collector._head, &ctx->collectors);
@@ -385,6 +387,12 @@ static struct flb_config_map config_map[] = {
      "scrape interval to collect netdev metrics from the node."
     },
 
+    {
+     FLB_CONFIG_MAP_TIME, "collector.sockstat.scrape_interval", "0",
+     0, FLB_FALSE, 0,
+     "scrape interval to collect sockstat metrics from the node."
+    },
+
     {
      FLB_CONFIG_MAP_TIME, "collector.filefd.scrape_interval", "0",
      0, FLB_FALSE, 0,

plugins/in_node_exporter_metrics/ne.h

@@ -33,7 +33,7 @@
 /* Default enabled metrics */
 
 #ifdef __linux__
-#define NE_DEFAULT_ENABLED_METRICS "cpu,cpufreq,meminfo,diskstats,filesystem,uname,stat,time,loadavg,vmstat,netdev,filefd,systemd,nvme,thermal_zone"
+#define NE_DEFAULT_ENABLED_METRICS "cpu,cpufreq,meminfo,diskstats,filesystem,uname,stat,time,loadavg,vmstat,netdev,sockstat,filefd,systemd,nvme,thermal_zone"
 #elif __APPLE__
 #define NE_DEFAULT_ENABLED_METRICS "cpu,loadavg,meminfo,diskstats,uname,netdev"
 #endif
@@ -140,6 +140,28 @@ struct flb_ne {
     struct cmt_gauge *darwin_noproto;
 #endif
 
+    /* sockstat_linux */
+    struct cmt_gauge *sockstat_sockets_used;
+    struct cmt_gauge *sockstat_TCP_alloc;
+    struct cmt_gauge *sockstat_TCP_inuse;
+    struct cmt_gauge *sockstat_TCP_mem;
+    struct cmt_gauge *sockstat_TCP_mem_bytes;
+    struct cmt_gauge *sockstat_TCP_orphan;
+    struct cmt_gauge *sockstat_TCP_tw;
+    struct cmt_gauge *sockstat_UDP_inuse;
+    struct cmt_gauge *sockstat_UDP_mem;
+    struct cmt_gauge *sockstat_UDP_mem_bytes;
+    struct cmt_gauge *sockstat_UDPLITE_inuse;
+    struct cmt_gauge *sockstat_RAW_inuse;
+    struct cmt_gauge *sockstat_FRAG_inuse;
+    struct cmt_gauge *sockstat_FRAG_memory;
+    struct cmt_gauge *sockstat_TCP6_inuse;
+    struct cmt_gauge *sockstat_UDP6_inuse;
+    struct cmt_gauge *sockstat_UDPLITE6_inuse;
+    struct cmt_gauge *sockstat_RAW6_inuse;
+    struct cmt_gauge *sockstat_FRAG6_inuse;
+    struct cmt_gauge *sockstat_FRAG6_memory;
+
     /* time */
     struct cmt_gauge *time;
 

plugins/in_node_exporter_metrics/ne_sockstat.c

@@ -0,0 +1,33 @@
+/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+
+/*  Fluent Bit
+ *  ==========
+ *  Copyright (C) 2015-2025 The Fluent Bit Authors
+ *
+ *  Licensed 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.
+ */
+
+#ifdef __linux__
+#include "ne_sockstat_linux.c"
+#else
+
+#include "ne.h"
+
+struct flb_ne_collector sockstat_collector = {
+    .name = "sockstat",
+    .cb_init = NULL,
+    .cb_update = NULL,
+    .cb_exit = NULL
+};
+
+#endif

plugins/in_node_exporter_metrics/ne_sockstat.h

@@ -0,0 +1,27 @@
+/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+
+/*  Fluent Bit
+ *  ==========
+ *  Copyright (C) 2015-2025 The Fluent Bit Authors
+ *
+ *  Licensed 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.
+ */
+
+#ifndef FLB_IN_NE_SOCKSTAT_H
+#define FLB_IN_NE_SOCKSTAT_H
+
+#include "ne.h"
+
+extern struct flb_ne_collector sockstat_collector;
+
+#endif