Skip to content

Commit 915897e

Browse files
[testbed] Add OtelArrow to TestMetric10kDPS (#43131)
This adds OtelArrow sender and receiver to the testbed and adds the protocol as a test case to TestMetric10kDPS. No changelog is necessary since there is no user facing changes or API changes. The test shows OtelArrow receiver fails to shutdown on SIGTERM signal. I had to replace a fatal error in TestCase.indicateError by a regular log message to avoid failing the entire suite when shutdown timeout for OtelArrow case. Results running locally: ``` Test |Result|Duration|CPU Avg%|CPU Max%|CPU Limit|RAM Avg MiB|RAM Max MiB|RAM Limit MiB|Sent Items|Received Items| ----------------------------------------|------|-------:|-------:|-------:|--------:|----------:|----------:|------------:|---------:|-------------:| Metric10kDPS/Carbon |PASS | 16s| 172.4| 179.9| 0.0| 59| 84| 0| 1050700| 1050700| Metric10kDPS/OTLP |PASS | 15s| 17.6| 18.1| 0.0| 62| 88| 0| 1050700| 1050700| Metric10kDPS/OTLP-HTTP |PASS | 16s| 20.9| 22.0| 0.0| 57| 81| 0| 1050700| 1050700| Metric10kDPS/SignalFx |PASS | 16s| 35.3| 36.7| 0.0| 61| 86| 0| 1050700| 1050700| Metric10kDPS/STEF |PASS | 17s| 12.1| 13.8| 0.0| 72| 115| 0| 1050700| 1050700| Metric10kDPS/OtelArrow |PASS | 25s| 22.9| 23.8| 0.0| 123| 183| 0| 1051400| 1051400|signal: killed Total duration: 104s ```
1 parent c15cc08 commit 915897e

File tree

13 files changed

+467
-27
lines changed

13 files changed

+467
-27
lines changed

cmd/opampsupervisor/go.mod

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,22 +38,27 @@ require (
3838
)
3939

4040
require (
41+
github.com/HdrHistogram/hdrhistogram-go v1.1.2 // indirect
4142
github.com/alecthomas/participle/v2 v2.1.4 // indirect
4243
github.com/antchfx/xmlquery v1.4.4 // indirect
4344
github.com/antchfx/xpath v1.3.5 // indirect
45+
github.com/apache/arrow-go/v18 v18.2.0 // indirect
4446
github.com/apache/thrift v0.22.0 // indirect
47+
github.com/axiomhq/hyperloglog v0.2.5 // indirect
4548
github.com/beorn7/perks v1.0.1 // indirect
4649
github.com/cenkalti/backoff/v4 v4.3.0 // indirect
4750
github.com/cenkalti/backoff/v5 v5.0.3 // indirect
4851
github.com/cespare/xxhash/v2 v2.3.0 // indirect
4952
github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
53+
github.com/dgryski/go-metro v0.0.0-20180109044635-280f6062b5bc // indirect
5054
github.com/ebitengine/purego v0.8.4 // indirect
5155
github.com/elastic/go-grok v0.3.1 // indirect
5256
github.com/elastic/lunes v0.1.0 // indirect
5357
github.com/expr-lang/expr v1.17.6 // indirect
5458
github.com/felixge/httpsnoop v1.0.4 // indirect
5559
github.com/foxboron/go-tpm-keyfiles v0.0.0-20250903184740-5d135037bd4d // indirect
5660
github.com/fsnotify/fsnotify v1.9.0 // indirect
61+
github.com/fxamacker/cbor/v2 v2.9.0 // indirect
5762
github.com/go-logr/logr v1.4.3 // indirect
5863
github.com/go-logr/stdr v1.2.2 // indirect
5964
github.com/go-ole/go-ole v1.3.0 // indirect
@@ -64,6 +69,7 @@ require (
6469
github.com/gogo/protobuf v1.3.2 // indirect
6570
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
6671
github.com/golang/snappy v1.0.0 // indirect
72+
github.com/google/flatbuffers v25.2.10+incompatible // indirect
6773
github.com/google/go-tpm v0.9.6 // indirect
6874
github.com/gorilla/mux v1.8.1 // indirect
6975
github.com/gorilla/websocket v1.5.3 // indirect
@@ -77,7 +83,9 @@ require (
7783
github.com/jonboulle/clockwork v0.5.0 // indirect
7884
github.com/jpillora/backoff v1.0.0 // indirect
7985
github.com/json-iterator/go v1.1.12 // indirect
86+
github.com/kamstrup/intmap v0.5.1 // indirect
8087
github.com/klauspost/compress v1.18.0 // indirect
88+
github.com/klauspost/cpuid/v2 v2.2.11 // indirect
8189
github.com/knadh/koanf/providers/confmap v1.0.0 // indirect
8290
github.com/leodido/go-syslog/v4 v4.2.0 // indirect
8391
github.com/leodido/ragel-machinery v0.0.0-20190525184631-5f46317e436b // indirect
@@ -98,7 +106,10 @@ require (
98106
github.com/open-telemetry/opentelemetry-collector-contrib/exporter/zipkinexporter v0.136.0 // indirect
99107
github.com/open-telemetry/opentelemetry-collector-contrib/internal/common v0.136.0 // indirect
100108
github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal v0.136.0 // indirect
109+
github.com/open-telemetry/opentelemetry-collector-contrib/internal/grpcutil v0.136.0 // indirect
110+
github.com/open-telemetry/opentelemetry-collector-contrib/internal/otelarrow v0.136.0 // indirect
101111
github.com/open-telemetry/opentelemetry-collector-contrib/internal/pdatautil v0.136.0 // indirect
112+
github.com/open-telemetry/opentelemetry-collector-contrib/internal/sharedcomponent v0.136.0 // indirect
102113
github.com/open-telemetry/opentelemetry-collector-contrib/pkg/core/xidutils v0.136.0 // indirect
103114
github.com/open-telemetry/opentelemetry-collector-contrib/pkg/golden v0.136.0 // indirect
104115
github.com/open-telemetry/opentelemetry-collector-contrib/pkg/ottl v0.136.0 // indirect
@@ -107,9 +118,11 @@ require (
107118
github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/jaeger v0.136.0 // indirect
108119
github.com/open-telemetry/opentelemetry-collector-contrib/pkg/translator/zipkin v0.136.0 // indirect
109120
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/jaegerreceiver v0.136.0 // indirect
121+
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/otelarrowreceiver v0.136.0 // indirect
110122
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/stefreceiver v0.136.0 // indirect
111123
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/syslogreceiver v0.136.0 // indirect
112124
github.com/open-telemetry/opentelemetry-collector-contrib/receiver/zipkinreceiver v0.136.0 // indirect
125+
github.com/open-telemetry/otel-arrow/go v0.43.0 // indirect
113126
github.com/openzipkin/zipkin-go v0.4.3 // indirect
114127
github.com/pierrec/lz4/v4 v4.1.22 // indirect
115128
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
@@ -132,7 +145,9 @@ require (
132145
github.com/twmb/murmur3 v1.1.8 // indirect
133146
github.com/ua-parser/uap-go v0.0.0-20240611065828-3a4781585db6 // indirect
134147
github.com/valyala/fastjson v1.6.4 // indirect
148+
github.com/x448/float16 v0.8.4 // indirect
135149
github.com/yusufpapurcu/wmi v1.2.4 // indirect
150+
github.com/zeebo/xxh3 v1.0.2 // indirect
136151
go.opentelemetry.io/auto/sdk v1.1.0 // indirect
137152
go.opentelemetry.io/collector v0.136.1-0.20251006153429-d00f05936513 // indirect
138153
go.opentelemetry.io/collector/client v1.42.1-0.20251006153429-d00f05936513 // indirect
@@ -215,9 +230,12 @@ require (
215230
go.yaml.in/yaml/v3 v3.0.4 // indirect
216231
golang.org/x/crypto v0.42.0 // indirect
217232
golang.org/x/exp v0.0.0-20250819193227-8b4c13bb791b // indirect
233+
golang.org/x/mod v0.27.0 // indirect
218234
golang.org/x/net v0.44.0 // indirect
219235
golang.org/x/sync v0.17.0 // indirect
220236
golang.org/x/text v0.29.0 // indirect
237+
golang.org/x/tools v0.36.0 // indirect
238+
golang.org/x/xerrors v0.0.0-20240903120638-7835f813f4da // indirect
221239
gonum.org/v1/gonum v0.16.0 // indirect
222240
google.golang.org/genproto/googleapis/api v0.0.0-20250825161204-c5933d9347a5 // indirect
223241
google.golang.org/genproto/googleapis/rpc v0.0.0-20250825161204-c5933d9347a5 // indirect
@@ -325,3 +343,11 @@ replace github.com/open-telemetry/opentelemetry-collector-contrib/internal/datad
325343
replace github.com/open-telemetry/opentelemetry-collector-contrib/pkg/datadog => ../../pkg/datadog
326344

327345
replace github.com/open-telemetry/opentelemetry-collector-contrib/internal/aws/ecsutil => ../../internal/aws/ecsutil
346+
347+
replace github.com/open-telemetry/opentelemetry-collector-contrib/internal/otelarrow => ../../internal/otelarrow
348+
349+
replace github.com/open-telemetry/opentelemetry-collector-contrib/receiver/otelarrowreceiver => ../../receiver/otelarrowreceiver
350+
351+
replace github.com/open-telemetry/opentelemetry-collector-contrib/exporter/otelarrowexporter => ../../exporter/otelarrowexporter
352+
353+
replace github.com/open-telemetry/opentelemetry-collector-contrib/internal/grpcutil => ../../internal/grpcutil

0 commit comments

Comments
 (0)