socket_summary add more tcp status

metricbeat/docs/fields.asciidoc

@@ -22083,6 +22083,36 @@ type: integer
 All TCP listening ports
 
 
+--
+
+*`system.socket.summary.tcp.all.established`*::
++
+--
+type: integer
+
+Number of established TCP connections
+
+
+--
+
+*`system.socket.summary.tcp.all.close_wait`*::
++
+--
+type: integer
+
+Number of TCP connections in _close_wait_ state
+
+
+--
+
+*`system.socket.summary.tcp.all.time_wait`*::
++
+--
+type: integer
+
+Number of TCP connections in _time_wait_ state
+
+
 --
 
 [float]

metricbeat/module/system/socket_summary/_meta/fields.yml

@@ -35,6 +35,18 @@
               type: integer
               description: >
                 All TCP listening ports
+            - name: established
+              type: integer
+              description: >
+                Number of established TCP connections
+            - name: close_wait
+              type: integer
+              description: >
+                Number of TCP connections in _close_wait_ state
+            - name: time_wait
+              type: integer
+              description: >
+                Number of TCP connections in _time_wait_ state
     - name: udp
       type: group
       description: >
@@ -51,3 +63,4 @@
                 All open TCP connections
 
 
+

metricbeat/module/system/socket_summary/socket_summary.go

@@ -64,11 +64,14 @@ func New(base mb.BaseMetricSet) (mb.MetricSet, error) {
 
 func calculateConnStats(conns []net.ConnectionStat) common.MapStr {
 	var (
-		allConns     = len(conns)
-		allListening = 0
-		tcpConns     = 0
-		tcpListening = 0
-		udpConns     = 0
+		allConns       = len(conns)
+		allListening   = 0
+		tcpConns       = 0
+		tcpListening   = 0
+		tcpClosewait   = 0
+		tcpEstablished = 0
+		tcpTimewait    = 0
+		udpConns       = 0
 	)
 
 	for _, conn := range conns {
@@ -78,7 +81,15 @@ func calculateConnStats(conns []net.ConnectionStat) common.MapStr {
 		switch conn.Type {
 		case syscall.SOCK_STREAM:
 			tcpConns++
-
+			if conn.Status == "ESTABLISHED" {
+				tcpEstablished++
+			}
+			if conn.Status == "CLOSE_WAIT" {
+				tcpClosewait++
+			}
+			if conn.Status == "TIME_WAIT" {
+				tcpTimewait++
+			}
 			if conn.Status == "LISTEN" {
 				tcpListening++
 			}
@@ -94,8 +105,11 @@ func calculateConnStats(conns []net.ConnectionStat) common.MapStr {
 		},
 		"tcp": common.MapStr{
 			"all": common.MapStr{
-				"count":     tcpConns,
-				"listening": tcpListening,
+				"count":       tcpConns,
+				"listening":   tcpListening,
+				"established": tcpEstablished,
+				"close_wait":  tcpClosewait,
+				"time_wait":   tcpTimewait,
 			},
 		},
 		"udp": common.MapStr{