Add container metrics receiver to collect CPU & Memory Usage (#1064)

Author: dhurley

.testcoverage.yaml

@@ -40,6 +40,8 @@ exclude:
     - ^test/.*$
     - app.go          # app.go and main.go should be tested by integration tests.
     - main.go
+    # ignore metadata generated files
+    - metadata/generated_.*\.go
     # ignore wrappers around gopsutil
     - internal/datasource/host
     - internal/watcher/process

go.mod

@@ -71,6 +71,7 @@ require (
 	go.opentelemetry.io/collector/receiver/receivertest v0.124.0
 	go.opentelemetry.io/collector/scraper v0.124.0
 	go.opentelemetry.io/collector/scraper/scraperhelper v0.124.0
+	go.opentelemetry.io/collector/scraper/scrapertest v0.124.0
 	go.opentelemetry.io/otel v1.35.0
 	go.uber.org/goleak v1.3.0
 	go.uber.org/zap v1.27.0

internal/collector/containermetricsreceiver/README.md

@@ -0,0 +1,18 @@
+# Container Metrics Receiver
+
+The Container Metrics receiver generates metrics about the container scraped from the cgroup files.
+
+## Configuration
+
+### Receiver Config
+
+The following settings are optional:
+- `collection_interval` (default = `10s`): This receiver collects metrics on an interval. This value must be a string readable by Golang's [time.ParseDuration](https://pkg.go.dev/time#ParseDuration). Valid time units are `ns`, `us` (or `µs`), `ms`, `s`, `m`, `h`.
+- `initial_delay` (default = `1s`): defines how long this receiver waits before starting.
+
+Example:
+```yaml
+containermetrics:
+  collection_interval: <duration> # default = 1m
+  initial_delay: <duration> # default = 1s
+```

internal/collector/containermetricsreceiver/doc.go

@@ -0,0 +1,8 @@
+// Copyright (c) F5, Inc.
+//
+// This source code is licensed under the Apache License, Version 2.0 license found in the
+// LICENSE file in the root directory of this source tree.
+
+//go:generate mdatagen metadata.yaml
+
+package containermetricsreceiver

internal/collector/containermetricsreceiver/documentation.md

@@ -0,0 +1,33 @@
+[comment]: <> (Code generated by mdatagen. DO NOT EDIT.)
+
+# containermetrics
+
+## Default Metrics
+
+The following metrics are emitted by default. Each of them can be disabled by applying the following configuration:
+
+```yaml
+metrics:
+  <metric_name>:
+    enabled: false
+```
+
+### system.memory.usage
+
+Bytes of memory in use.
+
+| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
+| ---- | ----------- | ---------- | ----------------------- | --------- |
+| By | Sum | Int | Cumulative | false |
+
+#### Attributes
+
+| Name | Description | Values |
+| ---- | ----------- | ------ |
+| state | Breakdown of memory usage by type. | Str: ``buffered``, ``cached``, ``inactive``, ``free``, ``slab_reclaimable``, ``slab_unreclaimable``, ``used`` |
+
+## Resource Attributes
+
+| Name | Description | Values | Enabled |
+| ---- | ----------- | ------ | ------- |
+| resource.id | The resource id. | Any Str | false |

internal/collector/containermetricsreceiver/factory.go

@@ -0,0 +1,55 @@
+// Copyright (c) F5, Inc.
+//
+// This source code is licensed under the Apache License, Version 2.0 license found in the
+// LICENSE file in the root directory of this source tree.
+
+package containermetricsreceiver
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nginx/agent/v3/internal/collector/containermetricsreceiver/internal/scraper/memoryscraper"
+
+	"github.com/nginx/agent/v3/internal/collector/containermetricsreceiver/internal/scraper/cpuscraper"
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/consumer"
+	"go.opentelemetry.io/collector/receiver"
+	"go.opentelemetry.io/collector/scraper/scraperhelper"
+
+	"github.com/nginx/agent/v3/internal/collector/containermetricsreceiver/internal/config"
+	"github.com/nginx/agent/v3/internal/collector/containermetricsreceiver/internal/metadata"
+)
+
+// nolint: ireturn
+func NewFactory() receiver.Factory {
+	return receiver.NewFactory(
+		metadata.Type,
+		config.CreateDefaultConfig,
+		receiver.WithMetrics(
+			createMetricsReceiver,
+			metadata.MetricsStability,
+		),
+	)
+}
+
+// nolint: ireturn
+func createMetricsReceiver(
+	_ context.Context,
+	params receiver.Settings,
+	rConf component.Config,
+	cons consumer.Metrics,
+) (receiver.Metrics, error) {
+	cfg, ok := rConf.(*config.Config)
+	if !ok {
+		return nil, errors.New("cast to metrics receiver config failed")
+	}
+
+	return scraperhelper.NewMetricsController(
+		&cfg.ControllerConfig,
+		params,
+		cons,
+		scraperhelper.AddFactoryWithConfig(cpuscraper.NewFactory(), cpuscraper.NewConfig(cfg)),
+		scraperhelper.AddFactoryWithConfig(memoryscraper.NewFactory(), memoryscraper.NewConfig(cfg)),
+	)
+}

internal/collector/containermetricsreceiver/generated_component_test.go

@@ -0,0 +1,23 @@
+// Copyright (c) F5, Inc.
+//
+// This source code is licensed under the Apache License, Version 2.0 license found in the
+// LICENSE file in the root directory of this source tree.
+
+package config
+
+import (
+	"go.opentelemetry.io/collector/component"
+	"go.opentelemetry.io/collector/scraper/scraperhelper"
+)
+
+type Config struct {
+	scraperhelper.ControllerConfig `mapstructure:",squash"`
+}
+
+// nolint: ireturn
+func CreateDefaultConfig() component.Config {
+	cfg := scraperhelper.NewDefaultControllerConfig()
+	return &Config{
+		ControllerConfig: cfg,
+	}
+}