Skip to content

Commit 0c6f673

Browse files
jose-mfjose-mf
committed
Add transform processor and s3 exporter
1 parent 6a8b279 commit 0c6f673

File tree

5 files changed

+70
-0
lines changed

5 files changed

+70
-0
lines changed

‎collector/go.mod‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@ require (
4848
github.com/aws/aws-sdk-go-v2/config v1.28.6 // indirect
4949
github.com/aws/aws-sdk-go-v2/credentials v1.17.47 // indirect
5050
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.21 // indirect
51+
github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.43 // indirect
5152
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.25 // indirect
5253
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.25 // indirect
5354
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1 // indirect
@@ -105,6 +106,7 @@ require (
105106
github.com/mostynb/go-grpc-compression v1.2.3 // indirect
106107
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
107108
github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector v0.116.0 // indirect
109+
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter v0.116.0 // indirect
108110
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusremotewriteexporter v0.116.0 // indirect
109111
github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension v0.116.0 // indirect
110112
github.com/open-telemetry/opentelemetry-collector-contrib/extension/sigv4authextension v0.116.0 // indirect
@@ -122,6 +124,7 @@ require (
122124
github.com/open-telemetry/opentelemetry-collector-contrib/processor/probabilisticsamplerprocessor v0.116.0 // indirect
123125
github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourceprocessor v0.116.0 // indirect
124126
github.com/open-telemetry/opentelemetry-collector-contrib/processor/spanprocessor v0.116.0 // indirect
127+
github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor v0.116.0 // indirect
125128
github.com/open-telemetry/opentelemetry-lambda/collector/processor/coldstartprocessor v0.98.0 // indirect
126129
github.com/open-telemetry/opentelemetry-lambda/collector/processor/decoupleprocessor v0.0.0-00010101000000-000000000000 // indirect
127130
github.com/open-telemetry/opentelemetry-lambda/collector/receiver/telemetryapireceiver v0.98.0 // indirect
@@ -143,6 +146,7 @@ require (
143146
github.com/tidwall/pretty v1.2.0 // indirect
144147
github.com/tidwall/tinylru v1.1.0 // indirect
145148
github.com/tidwall/wal v1.1.8 // indirect
149+
github.com/tilinna/clock v1.1.0 // indirect
146150
github.com/tklauser/go-sysconf v0.3.12 // indirect
147151
github.com/tklauser/numcpus v0.6.1 // indirect
148152
github.com/ua-parser/uap-go v0.0.0-20240611065828-3a4781585db6 // indirect

‎collector/go.sum‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@ github.com/aws/aws-sdk-go-v2/credentials v1.17.47 h1:48bA+3/fCdi2yAwVt+3COvmatZ6
2020
github.com/aws/aws-sdk-go-v2/credentials v1.17.47/go.mod h1:+KdckOejLW3Ks3b0E3b5rHsr2f9yuORBum0WPnE5o5w=
2121
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.21 h1:AmoU1pziydclFT/xRV+xXE/Vb8fttJCLRPv8oAkprc0=
2222
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.21/go.mod h1:AjUdLYe4Tgs6kpH4Bv7uMZo7pottoyHMn4eTcIcneaY=
23+
github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.43 h1:iLdpkYZ4cXIQMO7ud+cqMWR1xK5ESbt1rvN77tRi1BY=
24+
github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.43/go.mod h1:OgbsKPAswXDd5kxnR4vZov69p3oYjbvUyIRBAAV0y9o=
2325
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.25 h1:s/fF4+yDQDoElYhfIVvSNyeCydfbuTKzhxSXDXCPasU=
2426
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.25/go.mod h1:IgPfDv5jqFIzQSNbUEMoitNooSMXjRSDkhXv8jiROvU=
2527
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.25 h1:ZntTCl5EsYnhN/IygQEUugpdwbhdkom9uHcbCftiGgA=
@@ -164,6 +166,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/confmap/provider/secre
164166
github.com/open-telemetry/opentelemetry-collector-contrib/confmap/provider/secretsmanagerprovider v0.116.0/go.mod h1:o5vVMl/Bl1hLCPz8qZZLjmUaYlLbGL6xpXV5zEHe2gI=
165167
github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector v0.116.0 h1:XFLkYR1xXwxapNuS0IrahYoHaaJxTyt5Kt3tHNCwHsc=
166168
github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector v0.116.0/go.mod h1:1kppUKh6r44eoCCuNTTCz3o2HIZXAhDvBxSFvDs0kwo=
169+
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter v0.116.0 h1:E/Lou5O/hhP2ti0wZ8eyXCqEPepaqmOPf5G2INXxSCU=
170+
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter v0.116.0/go.mod h1:MlQ89zsPv9LVqXVllrp9ukc9S7sqC+446jbAYg7JUQY=
167171
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusremotewriteexporter v0.116.0 h1:kDPTGIKqGR52zV0vvGtJUi/dLgGO9lPCAJY+oUkO8gU=
168172
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusremotewriteexporter v0.116.0/go.mod h1:9DGVPNNo9jsJkwNG2PFlXM/NPd/rx9KG5nOmjva9CyA=
169173
github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension v0.116.0 h1:hL41C0+5mDDJ/ZcvAaMx7HuPR8DSXh619aXZRlwL5S8=
@@ -202,6 +206,8 @@ github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourceproc
202206
github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourceprocessor v0.116.0/go.mod h1:H1T/KD5SwsI/dQlavg0Bo+6gXuRYyxo0qdmCdLVbT0w=
203207
github.com/open-telemetry/opentelemetry-collector-contrib/processor/spanprocessor v0.116.0 h1:gWROitbdyfTt2HJYZQOJse5ii2nO5qvc3hhDzST8d48=
204208
github.com/open-telemetry/opentelemetry-collector-contrib/processor/spanprocessor v0.116.0/go.mod h1:E+vLogB2REjq4+4yGqEer0eCSbSDMBNEvvx3BfFQgE0=
209+
github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor v0.116.0 h1:a48/8x5VSZSSBkdifVC0mSgNtdJ0M0GcRtX98VVd4nk=
210+
github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor v0.116.0/go.mod h1:5MKetAGO0XkoZSqdoZhfxSoFq3hn7zmEYF4Yjf+i+CI=
205211
github.com/pierrec/lz4/v4 v4.1.21 h1:yOVMLb6qSIDP67pl/5F7RepeKYu/VmTyEXvuMI5d9mQ=
206212
github.com/pierrec/lz4/v4 v4.1.21/go.mod h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
207213
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
@@ -246,6 +252,8 @@ github.com/tidwall/tinylru v1.1.0 h1:XY6IUfzVTU9rpwdhKUF6nQdChgCdGjkMfLzbWyiau6I
246252
github.com/tidwall/tinylru v1.1.0/go.mod h1:3+bX+TJ2baOLMWTnlyNWHh4QMnFyARg2TLTQ6OFbzw8=
247253
github.com/tidwall/wal v1.1.8 h1:2qDSGdAdjaY3PEvHRva+9UFqgk+ef7cOiW1Qn5JH1y0=
248254
github.com/tidwall/wal v1.1.8/go.mod h1:r6lR1j27W9EPalgHiB7zLJDYu3mzW5BQP5KrzBpYY/E=
255+
github.com/tilinna/clock v1.1.0 h1:6IQQQCo6KoBxVudv6gwtY8o4eDfhHo8ojA5dP0MfhSs=
256+
github.com/tilinna/clock v1.1.0/go.mod h1:ZsP7BcY7sEEz7ktc0IVy8Us6boDrK8VradlKRUGfOao=
249257
github.com/tklauser/go-sysconf v0.3.12 h1:0QaGUFOdQaIVdPgfITYzaTegZvdCjmYO52cSFAEVmqU=
250258
github.com/tklauser/go-sysconf v0.3.12/go.mod h1:Ho14jnntGE1fpdOqQEEaiKRpvIavV0hSfmBq8nJbHYI=
251259
github.com/tklauser/numcpus v0.6.1 h1:ng9scYS7az0Bk4OZLvrNXNSAO2Pxr1XXRAPyjhIx+Fk=

‎collector/lambdacomponents/exporter/awss3.go‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
//go:build lambdacomponents.custom && (lambdacomponents.all || lambdacomponents.exporter.all || lambdacomponents.exporter.awss3)
2+
3+
// Copyright The OpenTelemetry Authors
4+
//
5+
// Licensed under the Apache License, Version 2.0 (the "License");
6+
// you may not use this file except in compliance with the License.
7+
// You may obtain a copy of the License at
8+
//
9+
// http://www.apache.org/licenses/LICENSE-2.0
10+
//
11+
// Unless required by applicable law or agreed to in writing, software
12+
// distributed under the License is distributed on an "AS IS" BASIS,
13+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
// See the License for the specific language governing permissions and
15+
// limitations under the License.
16+
17+
package exporter
18+
19+
import (
20+
"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter"
21+
"go.opentelemetry.io/collector/exporter"
22+
)
23+
24+
func init() {
25+
Factories = append(Factories, func(extensionId string) exporter.Factory {
26+
return awss3exporter.NewFactory()
27+
})
28+
}

‎collector/lambdacomponents/go.mod‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@ go 1.23.1
55
require (
66
github.com/open-telemetry/opentelemetry-collector-contrib/connector/spanmetricsconnector v0.116.0
77
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/prometheusremotewriteexporter v0.116.0
8+
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/awss3exporter v0.116.0
89
github.com/open-telemetry/opentelemetry-collector-contrib/extension/basicauthextension v0.116.0
910
github.com/open-telemetry/opentelemetry-collector-contrib/extension/sigv4authextension v0.116.0
1011
github.com/open-telemetry/opentelemetry-collector-contrib/processor/attributesprocessor v0.116.0
@@ -14,6 +15,7 @@ require (
1415
github.com/open-telemetry/opentelemetry-collector-contrib/processor/spanprocessor v0.116.0
1516
github.com/open-telemetry/opentelemetry-lambda/collector/processor/coldstartprocessor v0.98.0
1617
github.com/open-telemetry/opentelemetry-lambda/collector/processor/decoupleprocessor v0.0.0-00010101000000-000000000000
18+
github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor v0.116.0
1719
github.com/open-telemetry/opentelemetry-lambda/collector/receiver/telemetryapireceiver v0.98.0
1820
go.opentelemetry.io/collector/component v0.116.0
1921
go.opentelemetry.io/collector/connector v0.116.0

‎collector/lambdacomponents/processor/transform.go‎

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
//go:build lambdacomponents.custom && (lambdacomponents.all || lambdacomponents.processor.all || lambdacomponents.processor.transform)
2+
3+
// Copyright The OpenTelemetry Authors
4+
//
5+
// Licensed under the Apache License, Version 2.0 (the "License");
6+
// you may not use this file except in compliance with the License.
7+
// You may obtain a copy of the License at
8+
//
9+
// http://www.apache.org/licenses/LICENSE-2.0
10+
//
11+
// Unless required by applicable law or agreed to in writing, software
12+
// distributed under the License is distributed on an "AS IS" BASIS,
13+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
// See the License for the specific language governing permissions and
15+
// limitations under the License.
16+
17+
package processor
18+
19+
import (
20+
"github.com/open-telemetry/opentelemetry-collector-contrib/processor/transformprocessor"
21+
"go.opentelemetry.io/collector/processor"
22+
)
23+
24+
func init() {
25+
Factories = append(Factories, func(extensionId string) processor.Factory {
26+
return transformprocessor.NewFactory()
27+
})
28+
}

0 commit comments

Comments
 (0)