Skip to content

Commit be8e93b

Browse files
duhminickduhminick
committed
Add new awsebsnvmereceiver
1 parent fbacc48 commit be8e93b

31 files changed

+3576
-0
lines changed

‎go.mod

+2
Original file line numberDiff line numberDiff line change
@@ -181,6 +181,7 @@ require (
181181
go.opentelemetry.io/collector/exporter/nopexporter v0.115.0
182182
go.opentelemetry.io/collector/extension v0.115.0
183183
go.opentelemetry.io/collector/extension/zpagesextension v0.115.0
184+
go.opentelemetry.io/collector/filter v0.115.0
184185
go.opentelemetry.io/collector/otelcol v0.115.0
185186
go.opentelemetry.io/collector/processor v0.115.0
186187
go.opentelemetry.io/collector/processor/batchprocessor v0.115.0
@@ -223,6 +224,7 @@ require (
223224
go.opentelemetry.io/collector/processor/processortest v0.115.0
224225
go.opentelemetry.io/collector/receiver/receivertest v0.115.0
225226
go.opentelemetry.io/collector/scraper v0.115.0
227+
go.uber.org/goleak v1.3.0
226228
)
227229

228230
require (

‎go.sum

+2
Original file line numberDiff line numberDiff line change
@@ -1676,6 +1676,8 @@ go.opentelemetry.io/collector/extension/zpagesextension v0.115.0 h1:zYrZZocc7n0Z
16761676
go.opentelemetry.io/collector/extension/zpagesextension v0.115.0/go.mod h1:OaXwNHF3MAcInBzCXrhXbTNHfIi9b7YGhXjtCFZqxNY=
16771677
go.opentelemetry.io/collector/featuregate v1.22.0 h1:1TUcdqA5VpEsX1Lrr6GG15CptZxDXxiu5AXgwpeNSR4=
16781678
go.opentelemetry.io/collector/featuregate v1.22.0/go.mod h1:3GaXqflNDVwWndNGBJ1+XJFy3Fv/XrFgjMN60N3z7yg=
1679+
go.opentelemetry.io/collector/filter v0.115.0 h1:pYnHUFDSHSjEIFZit+CU09itVkDXgV+WcV2HOkjvQcE=
1680+
go.opentelemetry.io/collector/filter v0.115.0/go.mod h1:aewQ+jmvpH88gPVWpNXiWSm+wwJVxTK4f23ex2NMd2c=
16791681
go.opentelemetry.io/collector/internal/fanoutconsumer v0.115.0 h1:6DRiSECeApFq6Jj5ug77rG53R6FzJEZBfygkyMEXdpg=
16801682
go.opentelemetry.io/collector/internal/fanoutconsumer v0.115.0/go.mod h1:vgQf5HQdmLQqpDHpDq2S3nTRoUuKtRcZpRTsy+UiwYw=
16811683
go.opentelemetry.io/collector/internal/memorylimiter v0.115.0 h1:U07IJxyHZXM6eLn8cOq/Lycx6DhQZhpDOuYtIRw/d6I=

‎receiver/awsebsnvmereceiver/config.go

+18
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
2+
// SPDX-License-Identifier: MIT
3+
4+
package awsebsnvmereceiver
5+
6+
import (
7+
"go.opentelemetry.io/collector/component"
8+
"go.opentelemetry.io/collector/receiver/scraperhelper"
9+
10+
"github.com/aws/amazon-cloudwatch-agent/receiver/awsebsnvmereceiver/internal/metadata"
11+
)
12+
13+
type Config struct {
14+
scraperhelper.ControllerConfig `mapstructure:",squash"`
15+
metadata.MetricsBuilderConfig `mapstructure:",squash"`
16+
}
17+
18+
var _ component.Config = (*Config)(nil)

‎receiver/awsebsnvmereceiver/config_test.go

+16
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
2+
// SPDX-License-Identifier: MIT
3+
4+
package awsebsnvmereceiver
5+
6+
import (
7+
"testing"
8+
9+
"github.com/stretchr/testify/require"
10+
)
11+
12+
func TestConfigValidate(t *testing.T) {
13+
c := Config{}
14+
err := c.Validate()
15+
require.NotNil(t, err)
16+
}

‎receiver/awsebsnvmereceiver/documentation.md

+107
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,107 @@
1+
[comment]: <> (Code generated by mdatagen. DO NOT EDIT.)
2+
3+
# awsebsnvmereceiver
4+
5+
## Default Metrics
6+
7+
The following metrics are emitted by default. Each of them can be disabled by applying the following configuration:
8+
9+
```yaml
10+
metrics:
11+
<metric_name>:
12+
enabled: false
13+
```
14+
15+
### diskio_ebs_ec2_instance_performance_exceeded_iops
16+
17+
The total time, in microseconds, that the EBS volume exceeded the attached Amazon EC2 instance's maximum IOPS performance
18+
19+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
20+
| ---- | ----------- | ---------- | ----------------------- | --------- |
21+
| us | Sum | Int | Cumulative | true |
22+
23+
### diskio_ebs_ec2_instance_performance_exceeded_tp
24+
25+
The total time, in microseconds, that the EBS volume exceeded the attached Amazon EC2 instance's maximum throughput performance
26+
27+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
28+
| ---- | ----------- | ---------- | ----------------------- | --------- |
29+
| us | Sum | Int | Cumulative | true |
30+
31+
### diskio_ebs_total_read_bytes
32+
33+
The total number of read bytes transferred
34+
35+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
36+
| ---- | ----------- | ---------- | ----------------------- | --------- |
37+
| By | Sum | Int | Cumulative | true |
38+
39+
### diskio_ebs_total_read_ops
40+
41+
The total number of completed read operations
42+
43+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
44+
| ---- | ----------- | ---------- | ----------------------- | --------- |
45+
| 1 | Sum | Int | Cumulative | true |
46+
47+
### diskio_ebs_total_read_time
48+
49+
The total time spent, in microseconds, by all completed read operations
50+
51+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
52+
| ---- | ----------- | ---------- | ----------------------- | --------- |
53+
| us | Sum | Int | Cumulative | true |
54+
55+
### diskio_ebs_total_write_bytes
56+
57+
The total number of write bytes transferred
58+
59+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
60+
| ---- | ----------- | ---------- | ----------------------- | --------- |
61+
| By | Sum | Int | Cumulative | true |
62+
63+
### diskio_ebs_total_write_ops
64+
65+
The total number of completed write operations
66+
67+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
68+
| ---- | ----------- | ---------- | ----------------------- | --------- |
69+
| 1 | Sum | Int | Cumulative | true |
70+
71+
### diskio_ebs_total_write_time
72+
73+
The total time spent, in microseconds, by all completed write operations
74+
75+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
76+
| ---- | ----------- | ---------- | ----------------------- | --------- |
77+
| us | Sum | Int | Cumulative | true |
78+
79+
### diskio_ebs_volume_performance_exceeded_iops
80+
81+
The total time, in microseconds, that IOPS demand exceeded the volume's provisioned IOPS performance
82+
83+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
84+
| ---- | ----------- | ---------- | ----------------------- | --------- |
85+
| us | Sum | Int | Cumulative | true |
86+
87+
### diskio_ebs_volume_performance_exceeded_tp
88+
89+
The total time, in microseconds, that throughput demand exceeded the volume's provisioned throughput performance
90+
91+
| Unit | Metric Type | Value Type | Aggregation Temporality | Monotonic |
92+
| ---- | ----------- | ---------- | ----------------------- | --------- |
93+
| us | Sum | Int | Cumulative | true |
94+
95+
### diskio_ebs_volume_queue_length
96+
97+
The number of read and write operations waiting to be completed
98+
99+
| Unit | Metric Type | Value Type |
100+
| ---- | ----------- | ---------- |
101+
| 1 | Gauge | Int |
102+
103+
## Resource Attributes
104+
105+
| Name | Description | Values | Enabled |
106+
| ---- | ----------- | ------ | ------- |
107+
| VolumeId | Unique identifier to the EBS volume | Any Str | true |

‎receiver/awsebsnvmereceiver/factory.go

+49
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
2+
// SPDX-License-Identifier: MIT
3+
4+
package awsebsnvmereceiver
5+
6+
import (
7+
"context"
8+
9+
"go.opentelemetry.io/collector/component"
10+
"go.opentelemetry.io/collector/consumer"
11+
"go.opentelemetry.io/collector/receiver"
12+
"go.opentelemetry.io/collector/receiver/scraperhelper"
13+
otelscraper "go.opentelemetry.io/collector/scraper"
14+
15+
"github.com/aws/amazon-cloudwatch-agent/receiver/awsebsnvmereceiver/internal/metadata"
16+
"github.com/aws/amazon-cloudwatch-agent/receiver/awsebsnvmereceiver/internal/nvme"
17+
)
18+
19+
func NewFactory() receiver.Factory {
20+
return receiver.NewFactory(metadata.Type,
21+
createDefaultConfig,
22+
receiver.WithMetrics(createMetricsReceiver, metadata.MetricsStability))
23+
}
24+
25+
func createDefaultConfig() component.Config {
26+
return &Config{
27+
scraperhelper.NewDefaultControllerConfig(),
28+
metadata.DefaultMetricsBuilderConfig(),
29+
}
30+
}
31+
32+
func createMetricsReceiver(
33+
_ context.Context,
34+
settings receiver.Settings,
35+
baseCfg component.Config,
36+
consumer consumer.Metrics,
37+
) (receiver.Metrics, error) {
38+
cfg := baseCfg.(*Config)
39+
nvmeScraper := newScraper(cfg, settings, &nvme.Util{})
40+
scraper, err := otelscraper.NewMetrics(nvmeScraper.scrape, otelscraper.WithStart(nvmeScraper.start), otelscraper.WithShutdown(nvmeScraper.shutdown))
41+
if err != nil {
42+
return nil, err
43+
}
44+
45+
return scraperhelper.NewScraperControllerReceiver(
46+
&cfg.ControllerConfig, settings, consumer,
47+
scraperhelper.AddScraper(metadata.Type, scraper),
48+
)
49+
}

‎receiver/awsebsnvmereceiver/factory_test.go

+30
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
2+
// SPDX-License-Identifier: MIT
3+
4+
package awsebsnvmereceiver
5+
6+
import (
7+
"context"
8+
"testing"
9+
10+
"github.com/stretchr/testify/assert"
11+
"github.com/stretchr/testify/require"
12+
"go.opentelemetry.io/collector/consumer/consumertest"
13+
"go.opentelemetry.io/collector/receiver/receivertest"
14+
)
15+
16+
func TestNewFactory(t *testing.T) {
17+
c := NewFactory()
18+
assert.NotNil(t, c)
19+
}
20+
21+
func TestCreateMetrics(t *testing.T) {
22+
metricsReceiver, _ := createMetricsReceiver(
23+
context.Background(),
24+
receivertest.NewNopSettings(),
25+
createDefaultConfig(),
26+
consumertest.NewNop(),
27+
)
28+
29+
require.NotNil(t, metricsReceiver)
30+
}

‎receiver/awsebsnvmereceiver/generated_component_test.go

+69
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎receiver/awsebsnvmereceiver/generated_package_test.go

+13
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)