Update dataset name and add a metric in process

cmd/otelcontribcol/go.mod

@@ -460,6 +460,7 @@ require (
 	github.com/influxdata/influxdb-observability/otel2influx v0.5.8 // indirect
 	github.com/influxdata/line-protocol/v2 v2.2.1 // indirect
 	github.com/ionos-cloud/sdk-go/v6 v6.1.9 // indirect
+	github.com/ishleenk17/opentelemetry-collector-contrib/processor/elasticprocessor v0.0.0-20240205053831-6d9a005cfe4b // indirect
 	github.com/jackc/chunkreader/v2 v2.0.1 // indirect
 	github.com/jackc/pgconn v1.14.0 // indirect
 	github.com/jackc/pgio v1.0.0 // indirect

processor/elasticprocessor/internal/hostmetrics/hostmetrics.go

@@ -15,7 +15,7 @@ var scraperToElasticDataset = map[string]string{
 	"memory":     "system.memory",
 	"network":    "system.network",
 	"paging":     "system.memory",
-	"processes":  "system.process",
+	"processes":  "system.process.summary",
 	"process":    "system.process",
 }
 

processor/elasticprocessor/internal/hostmetrics/process.go

@@ -7,7 +7,7 @@ import (
 
 func addProcessMetrics(metrics pmetric.MetricSlice, dataset string) error {
 	var timestamp pcommon.Timestamp
-	var threads, memUsage, memVirtual int64
+	var threads, memUsage, memVirtual, fdOpen int64
 	var memUtil float64
 
 	for i := 0; i < metrics.Len(); i++ {
@@ -28,6 +28,10 @@ func addProcessMetrics(metrics pmetric.MetricSlice, dataset string) error {
 			dp := metric.Sum().DataPoints().At(0)
 			timestamp = dp.Timestamp()
 			memVirtual = dp.IntValue()
+		} else if metric.Name() == "process.open_file_descriptors" {
+			dp := metric.Sum().DataPoints().At(0)
+			timestamp = dp.Timestamp()
+			fdOpen = dp.IntValue()
 		}
 	}
 
@@ -58,6 +62,12 @@ func addProcessMetrics(metrics pmetric.MetricSlice, dataset string) error {
 			timestamp: timestamp,
 			intValue:  &memVirtual,
 		},
+		metric{
+			dataType:  Sum,
+			name:      "system.process.fd.open",
+			timestamp: timestamp,
+			intValue:  &fdOpen,
+		},
 	)
 
 	return nil