Skip to content

Commit 9e8517d

Browse files
obs-gh-alexlewobs-gh-alexlew
committed
initial commit for k8s attributes processor
1 parent 0f063ea commit 9e8517d

File tree

12 files changed

+578
-0
lines changed

12 files changed

+578
-0
lines changed

‎cmd/components/processors/observek8sattributesprocessor/README.md

Whitespace-only changes.

‎cmd/components/processors/observek8sattributesprocessor/config.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
package observek8sattributesprocessor
2+
3+
type Config struct {
4+
}
5+
6+
func (cfg *Config) Validate() error {
7+
return nil
8+
}

‎cmd/components/processors/observek8sattributesprocessor/doc.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
//go:generate mdatagen metadata.yaml
2+
3+
// package observek8sattributesprocessor implements a processor which
4+
// calculates and attaches additional k8s attributes
5+
package observek8sattributesprocessor

‎cmd/components/processors/observek8sattributesprocessor/factory.go

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package observek8sattributesprocessor
2+
3+
import (
4+
"go.opentelemetry.io/collector/component"
5+
"go.opentelemetry.io/collector/consumer"
6+
"go.opentelemetry.io/collector/processor"
7+
8+
"observe/agent/cmd/components/processors/observek8sattributesprocessor/internal/metadata"
9+
)
10+
11+
var processorCapabilities = consumer.Capabilities{MutatesData: true}
12+
13+
func NewFactory() processor.Factory {
14+
return processor.NewFactory(
15+
metadata.Type,
16+
createDefaultConfig,
17+
)
18+
}
19+
20+
func createDefaultConfig() component.Config {
21+
return &Config{}
22+
}

‎cmd/components/processors/observek8sattributesprocessor/generated_component_test.go

Lines changed: 149 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cmd/components/processors/observek8sattributesprocessor/generated_package_test.go

Lines changed: 12 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cmd/components/processors/observek8sattributesprocessor/go.mod

Lines changed: 59 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,59 @@
1+
module observe/agent/processor/observek8sattributesprocessor
2+
3+
go 1.22.3
4+
5+
require (
6+
github.com/stretchr/testify v1.9.0
7+
go.opentelemetry.io/collector/component v0.105.0
8+
go.opentelemetry.io/collector/config/configtelemetry v0.105.0
9+
go.opentelemetry.io/collector/confmap v0.105.0
10+
go.opentelemetry.io/collector/consumer v0.105.0
11+
go.opentelemetry.io/collector/pdata v1.12.0
12+
go.opentelemetry.io/collector/processor v0.105.0
13+
go.opentelemetry.io/otel/metric v1.28.0
14+
go.opentelemetry.io/otel/trace v1.28.0
15+
go.uber.org/goleak v1.3.0
16+
)
17+
18+
require (
19+
github.com/beorn7/perks v1.0.1 // indirect
20+
github.com/cespare/xxhash/v2 v2.3.0 // indirect
21+
github.com/davecgh/go-spew v1.1.1 // indirect
22+
github.com/go-logr/logr v1.4.2 // indirect
23+
github.com/go-logr/stdr v1.2.2 // indirect
24+
github.com/go-viper/mapstructure/v2 v2.0.0-alpha.1 // indirect
25+
github.com/gogo/protobuf v1.3.2 // indirect
26+
github.com/google/uuid v1.6.0 // indirect
27+
github.com/hashicorp/go-version v1.7.0 // indirect
28+
github.com/json-iterator/go v1.1.12 // indirect
29+
github.com/knadh/koanf/maps v0.1.1 // indirect
30+
github.com/knadh/koanf/providers/confmap v0.1.0 // indirect
31+
github.com/knadh/koanf/v2 v2.1.1 // indirect
32+
github.com/mitchellh/copystructure v1.2.0 // indirect
33+
github.com/mitchellh/reflectwalk v1.0.2 // indirect
34+
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
35+
github.com/modern-go/reflect2 v1.0.2 // indirect
36+
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
37+
github.com/pmezard/go-difflib v1.0.0 // indirect
38+
github.com/prometheus/client_golang v1.19.1 // indirect
39+
github.com/prometheus/client_model v0.6.1 // indirect
40+
github.com/prometheus/common v0.55.0 // indirect
41+
github.com/prometheus/procfs v0.15.1 // indirect
42+
go.opentelemetry.io/collector/featuregate v1.12.0 // indirect
43+
go.opentelemetry.io/collector/internal/globalgates v0.105.0 // indirect
44+
go.opentelemetry.io/collector/pdata/pprofile v0.105.0 // indirect
45+
go.opentelemetry.io/collector/pdata/testdata v0.105.0 // indirect
46+
go.opentelemetry.io/otel v1.28.0 // indirect
47+
go.opentelemetry.io/otel/exporters/prometheus v0.50.0 // indirect
48+
go.opentelemetry.io/otel/sdk v1.28.0 // indirect
49+
go.opentelemetry.io/otel/sdk/metric v1.28.0 // indirect
50+
go.uber.org/multierr v1.11.0 // indirect
51+
go.uber.org/zap v1.27.0 // indirect
52+
golang.org/x/net v0.26.0 // indirect
53+
golang.org/x/sys v0.21.0 // indirect
54+
golang.org/x/text v0.16.0 // indirect
55+
google.golang.org/genproto/googleapis/rpc v0.0.0-20240701130421-f6361c86f094 // indirect
56+
google.golang.org/grpc v1.65.0 // indirect
57+
google.golang.org/protobuf v1.34.2 // indirect
58+
gopkg.in/yaml.v3 v3.0.1 // indirect
59+
)

0 commit comments

Comments
 (0)