From ba4b92dc747f9e239a1d4f2fc478d80ccf12dfbd Mon Sep 17 00:00:00 2001 From: Bryan Huhta <32787160+bryanhuhta@users.noreply.github.com> Date: Mon, 28 Oct 2024 11:47:39 -0500 Subject: [PATCH] Add rideshare example for integrating with k6 (#3648) --- .../golang-push/rideshare-k6/Dockerfile | 6 + .../rideshare-k6/Dockerfile.load-generator | 6 + .../golang-push/rideshare-k6/README.md | 31 ++ .../golang-push/rideshare-k6/bike/bike.go | 12 + .../golang-push/rideshare-k6/car/car.go | 12 + .../rideshare-k6/docker-compose.yml | 65 ++++ .../golang-push/rideshare-k6/go.mod | 40 +++ .../golang-push/rideshare-k6/go.sum | 92 ++++++ .../golang-push/rideshare-k6/go.work | 5 + .../golang-push/rideshare-k6/go.work.sum | 214 ++++++++++++++ .../datasources/pyroscope.yml | 14 + .../plugins/explore-profiles.yml | 11 + .../golang-push/rideshare-k6/load.js | 25 ++ .../golang-push/rideshare-k6/loadgen.go | 143 +++++++++ .../golang-push/rideshare-k6/main.go | 143 +++++++++ .../golang-push/rideshare-k6/nginx.conf | 23 ++ .../rideshare-k6/rideshare/rideshare.go | 279 ++++++++++++++++++ .../rideshare-k6/scooter/scooter.go | 12 + .../golang-push/rideshare-k6/utility/pool.go | 92 ++++++ .../golang-push/rideshare-k6/utility/util.go | 35 +++ .../rideshare-k6/utility/utility.go | 75 +++++ 21 files changed, 1335 insertions(+) create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile.load-generator create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/README.md create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/bike/bike.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/car/car.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/docker-compose.yml create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.mod create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.sum create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work.sum create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/datasources/pyroscope.yml create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/plugins/explore-profiles.yml create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/load.js create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/loadgen.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/main.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/nginx.conf create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/rideshare/rideshare.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/scooter/scooter.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/pool.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/util.go create mode 100644 examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/utility.go diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile new file mode 100644 index 0000000000..4e457cbf69 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile @@ -0,0 +1,6 @@ +FROM golang:1.22.7 + +WORKDIR /go/src/app +COPY . . +RUN go build main.go +CMD ["./main"] diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile.load-generator b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile.load-generator new file mode 100644 index 0000000000..8ebba97b22 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/Dockerfile.load-generator @@ -0,0 +1,6 @@ +FROM golang:1.22.7 + +WORKDIR /go/src/app +COPY . . +RUN go build loadgen.go +CMD ["./loadgen"] diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/README.md b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/README.md new file mode 100644 index 0000000000..cf32412f7d --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/README.md @@ -0,0 +1,31 @@ +# Pyroscope k6 integration + +This example demonstrates Pyroscope's k6 integration. This example requires k6 +to be installed. To install k6, see: https://grafana.com/docs/k6/latest/set-up/install-k6/. + +## Running the example + +To run the example, use the following command to start all the necessary services. + +``` +docker compose up +``` + +This includes the following services: + +- A Pyroscope server (http://localhost:4040) +- Grafana instance with Explore Profiles and a Pyroscope data source installed (http://localhost:3000) +- An nginx load balancer for the Rideshare services (http://localhost:5001) + +> [!NOTE] +> We use nginx as a load balancer for the Rideshare services to simplify the +> load test script. Without nginx, the k6 load test would need to be aware of +> each Rideshare instance, resulting in tests with unnecessary boilerplate which +> would generally not be seen in the real world. + +Once Docker Compose is running, use the following command to execute a k6 load +test against the Rideshare service. + +``` +k6 run load.js +``` diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/bike/bike.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/bike/bike.go new file mode 100644 index 0000000000..98ad8325fb --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/bike/bike.go @@ -0,0 +1,12 @@ +package bike + +import ( + "context" + "rideshare/rideshare" + "rideshare/utility" +) + +func OrderBike(ctx context.Context, searchRadius int64) { + rideshare.Log.Printf(ctx, "ordering bike, with searchRadius=%d", searchRadius) + utility.FindNearestVehicle(ctx, searchRadius, "bike") +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/car/car.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/car/car.go new file mode 100644 index 0000000000..16898fb8ea --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/car/car.go @@ -0,0 +1,12 @@ +package car + +import ( + "context" + "rideshare/rideshare" + "rideshare/utility" +) + +func OrderCar(ctx context.Context, searchRadius int64) { + rideshare.Log.Printf(ctx, "ordering car, with searchRadius=%d", searchRadius) + utility.FindNearestVehicle(ctx, searchRadius, "car") +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/docker-compose.yml b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/docker-compose.yml new file mode 100644 index 0000000000..fb387b7802 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/docker-compose.yml @@ -0,0 +1,65 @@ +services: + us-east: + ports: + - 5000 + environment: + - REGION=us-east + - PYROSCOPE_SERVER_ADDRESS=http://pyroscope:4040 + - PARAMETERS_POOL_SIZE=1000 + - PARAMETERS_POOL_BUFFER_SIZE_KB=1000 + build: + context: . + eu-north: + ports: + - 5000 + environment: + - REGION=eu-north + - PYROSCOPE_SERVER_ADDRESS=http://pyroscope:4040 + build: + context: . + ap-south: + ports: + - 5000 + environment: + - REGION=ap-south + - PYROSCOPE_SERVER_ADDRESS=http://pyroscope:4040 + build: + context: . + + nginx: + image: nginx:latest + ports: + - 5001:80 + volumes: + - ./nginx.conf:/etc/nginx/nginx.conf + depends_on: + - us-east + - eu-north + - ap-south + + pyroscope: + image: grafana/pyroscope:latest + ports: + - 4040:4040 + + load-generator: + build: + context: . + dockerfile: Dockerfile.load-generator + environment: + - PYROSCOPE_SERVER_ADDRESS=http://pyroscope:4040 + - RIDESHARE_URL=http://nginx:80 + - VUS=1 + - SLEEP=500ms + + grafana: + image: grafana/grafana:latest + environment: + - GF_INSTALL_PLUGINS=grafana-pyroscope-app + - GF_AUTH_ANONYMOUS_ENABLED=true + - GF_AUTH_ANONYMOUS_ORG_ROLE=Admin + - GF_AUTH_DISABLE_LOGIN_FORM=true + volumes: + - ./grafana-provisioning:/etc/grafana/provisioning + ports: + - 3000:3000 diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.mod b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.mod new file mode 100644 index 0000000000..922e4655fa --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.mod @@ -0,0 +1,40 @@ +module rideshare + +go 1.22.7 + +require ( + github.com/agoda-com/opentelemetry-logs-go v0.4.1 + github.com/grafana/otel-profiling-go v0.5.1 + github.com/grafana/pyroscope-go v1.1.1 + go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.47.0 + go.opentelemetry.io/otel v1.22.0 + go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.22.0 + go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.22.0 + go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.20.0 + go.opentelemetry.io/otel/sdk v1.22.0 + go.opentelemetry.io/otel/trace v1.22.0 + github.com/grafana/pyroscope-go/x/k6 v0.0.0-20241003203156-a917cea171d3 +) + +require ( + github.com/cenkalti/backoff/v4 v4.2.1 // indirect + github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect + github.com/felixge/httpsnoop v1.0.4 // indirect + github.com/go-logr/logr v1.4.1 // indirect + github.com/go-logr/stdr v1.2.2 // indirect + github.com/golang/protobuf v1.5.3 // indirect + github.com/grafana/pyroscope-go/godeltaprof v0.1.8 // indirect + github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1 // indirect + github.com/klauspost/compress v1.17.8 // indirect + github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect + go.opentelemetry.io/otel/metric v1.22.0 // indirect + go.opentelemetry.io/proto/otlp v1.0.0 // indirect + go.uber.org/goleak v1.3.0 // indirect + golang.org/x/net v0.20.0 // indirect + golang.org/x/sys v0.16.0 // indirect + golang.org/x/text v0.14.0 // indirect + google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac // indirect + google.golang.org/grpc v1.61.0 // indirect + google.golang.org/protobuf v1.33.0 // indirect +) diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.sum b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.sum new file mode 100644 index 0000000000..7ee6af5451 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.sum @@ -0,0 +1,92 @@ +github.com/agoda-com/opentelemetry-logs-go v0.4.1 h1:PWGqIxkEEg4HIjnHsHmNa+yGu0lhxHz4XPGKeT4o6T0= +github.com/agoda-com/opentelemetry-logs-go v0.4.1/go.mod h1:CeDuVaK9yCWN+8UjOW8AciYJE0rl7K/mw4ejBntGYkc= +github.com/cenkalti/backoff/v4 v4.2.1 h1:y4OZtCnogmCPw98Zjyt5a6+QwPLGkiQsYW5oUqylYbM= +github.com/cenkalti/backoff/v4 v4.2.1/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM= +github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg= +github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U= +github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= +github.com/go-logr/logr v1.3.0/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY= +github.com/go-logr/logr v1.4.1 h1:pKouT5E8xu9zeFC39JXRDukb6JFQPXM5p5I91188VAQ= +github.com/go-logr/logr v1.4.1/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY= +github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= +github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= +github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= +github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= +github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= +github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= +github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= +github.com/grafana/otel-profiling-go v0.5.1 h1:stVPKAFZSa7eGiqbYuG25VcqYksR6iWvF3YH66t4qL8= +github.com/grafana/otel-profiling-go v0.5.1/go.mod h1:ftN/t5A/4gQI19/8MoWurBEtC6gFw8Dns1sJZ9W4Tls= +github.com/grafana/pyroscope-go v1.1.1 h1:PQoUU9oWtO3ve/fgIiklYuGilvsm8qaGhlY4Vw6MAcQ= +github.com/grafana/pyroscope-go v1.1.1/go.mod h1:Mw26jU7jsL/KStNSGGuuVYdUq7Qghem5P8aXYXSXG88= +github.com/grafana/pyroscope-go/godeltaprof v0.1.8 h1:iwOtYXeeVSAeYefJNaxDytgjKtUuKQbJqgAIjlnicKg= +github.com/grafana/pyroscope-go/godeltaprof v0.1.8/go.mod h1:2+l7K7twW49Ct4wFluZD3tZ6e0SjanjcUUBPVD/UuGU= +github.com/grafana/pyroscope-go/x/k6 v0.0.0-20241003203156-a917cea171d3 h1:GtwQDlBz8aJHMy2Ko28UDRGgGzi7v4Vf20+ZyXaGy7M= +github.com/grafana/pyroscope-go/x/k6 v0.0.0-20241003203156-a917cea171d3/go.mod h1:nfbW6/4ke3ywlqLb+Zgr9t1z9Zv3m+2ImUp+vbkzHpc= +github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1 h1:6UKoz5ujsI55KNpsJH3UwCq3T8kKbZwNZBNPuTTje8U= +github.com/grpc-ecosystem/grpc-gateway/v2 v2.18.1/go.mod h1:YvJ2f6MplWDhfxiUC3KpyTy76kYUZA4W3pTv/wdKQ9Y= +github.com/klauspost/compress v1.17.8 h1:YcnTYrq7MikUT7k0Yb5eceMmALQPYBW/Xltxn0NAMnU= +github.com/klauspost/compress v1.17.8/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U= +github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= +github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= +github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= +github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk= +github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= +go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.47.0 h1:sv9kVfal0MK0wBMCOGr+HeJm9v803BkJxGrk2au7j08= +go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.47.0/go.mod h1:SK2UL73Zy1quvRPonmOmRDiWk1KBV3LyIeeIxcEApWw= +go.opentelemetry.io/otel v1.21.0/go.mod h1:QZzNPQPm1zLX4gZK4cMi+71eaorMSGT3A4znnUvNNEo= +go.opentelemetry.io/otel v1.22.0 h1:xS7Ku+7yTFvDfDraDIJVpw7XPyuHlB9MCiqqX5mcJ6Y= +go.opentelemetry.io/otel v1.22.0/go.mod h1:eoV4iAi3Ea8LkAEI9+GFT44O6T/D0GWAVFyZVCC6pMI= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.22.0 h1:9M3+rhx7kZCIQQhQRYaZCdNu1V73tm4TvXs2ntl98C4= +go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.22.0/go.mod h1:noq80iT8rrHP1SfybmPiRGc9dc5M8RPmGvtwo7Oo7tc= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.22.0 h1:FyjCyI9jVEfqhUh2MoSkmolPjfh5fp2hnV0b0irxH4Q= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.22.0/go.mod h1:hYwym2nDEeZfG/motx0p7L7J1N1vyzIThemQsb4g2qY= +go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.20.0 h1:4s9HxB4azeeQkhY0GE5wZlMj4/pz8tE5gx2OQpGUw58= +go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.20.0/go.mod h1:djVA3TUJ2fSdMX0JE5XxFBOaZzprElJoP7fD4vnV2SU= +go.opentelemetry.io/otel/metric v1.21.0/go.mod h1:o1p3CA8nNHW8j5yuQLdc1eeqEaPfzug24uvsyIEJRWM= +go.opentelemetry.io/otel/metric v1.22.0 h1:lypMQnGyJYeuYPhOM/bgjbFM6WE44W1/T45er4d8Hhg= +go.opentelemetry.io/otel/metric v1.22.0/go.mod h1:evJGjVpZv0mQ5QBRJoBF64yMuOf4xCWdXjK8pzFvliY= +go.opentelemetry.io/otel/sdk v1.21.0/go.mod h1:Nna6Yv7PWTdgJHVRD9hIYywQBRx7pbox6nwBnZIxl/E= +go.opentelemetry.io/otel/sdk v1.22.0 h1:6coWHw9xw7EfClIC/+O31R8IY3/+EiRFHevmHafB2Gw= +go.opentelemetry.io/otel/sdk v1.22.0/go.mod h1:iu7luyVGYovrRpe2fmj3CVKouQNdTOkxtLzPvPz1DOc= +go.opentelemetry.io/otel/trace v1.21.0/go.mod h1:LGbsEB0f9LGjN+OZaQQ26sohbOmiMR+BaslueVtS/qQ= +go.opentelemetry.io/otel/trace v1.22.0 h1:Hg6pPujv0XG9QaVbGOBVHunyuLcCC3jN7WEhPx83XD0= +go.opentelemetry.io/otel/trace v1.22.0/go.mod h1:RbbHXVqKES9QhzZq/fE5UnOSILqRt40a21sPw2He1xo= +go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lIVU/I= +go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM= +go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto= +go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE= +golang.org/x/net v0.20.0 h1:aCL9BSgETF1k+blQaYUBx9hJ9LOGP3gAVemcZlf1Kpo= +golang.org/x/net v0.20.0/go.mod h1:z8BVo6PvndSri0LbOE3hAn0apkU+1YvI6E70E9jsnvY= +golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.16.0 h1:xWw16ngr6ZMtmxDyKyIgsE93KNKz5HKmMa3b8ALHidU= +golang.org/x/sys v0.16.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ= +golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +google.golang.org/genproto v0.0.0-20240102182953-50ed04b92917 h1:nz5NESFLZbJGPFxDT/HCn+V1mZ8JGNoY4nUpmW/Y2eg= +google.golang.org/genproto v0.0.0-20240102182953-50ed04b92917/go.mod h1:pZqR+glSb11aJ+JQcczCvgf47+duRuzNSKqE8YAQnV0= +google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac h1:OZkkudMUu9LVQMCoRUbI/1p5VCo9BOrlvkqMvWtqa6s= +google.golang.org/genproto/googleapis/api v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:B5xPO//w8qmBDjGReYLpR6UJPnkldGkCSMoH/2vxJeg= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac h1:nUQEQmH/csSvFECKYRv6HWEyypysidKl2I6Qpsglq/0= +google.golang.org/genproto/googleapis/rpc v0.0.0-20240116215550-a9fa1716bcac/go.mod h1:daQN87bsDqDoe316QbbvX60nMoJQa4r6Ds0ZuoAe5yA= +google.golang.org/grpc v1.61.0 h1:TOvOcuXn30kRao+gfcvsebNEa5iZIiLkisYEkf7R7o0= +google.golang.org/grpc v1.61.0/go.mod h1:VUbo7IFqmF1QtCAstipjG0GIoq49KvMe9+h1jFLBNJs= +google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= +google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= +google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI= +google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work new file mode 100644 index 0000000000..bd40e0e02b --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work @@ -0,0 +1,5 @@ +go 1.22.7 + +use ( + . +) diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work.sum b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work.sum new file mode 100644 index 0000000000..7e117f51f5 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/go.work.sum @@ -0,0 +1,214 @@ +cloud.google.com/go/compute v1.21.0 h1:JNBsyXVoOoNJtTQcnEY5uYpZIbeCTYIeDe0Xh1bySMk= +cloud.google.com/go/compute v1.23.0 h1:tP41Zoavr8ptEqaW6j+LQOnyBBhO7OkOMAGrgLopTwY= +cloud.google.com/go/compute v1.23.3 h1:6sVlXXBmbd7jNX0Ipq0trII3e4n1/MsADLK6a+aiVlk= +cloud.google.com/go/compute v1.23.3/go.mod h1:VCgBUoMnIVIR0CscqQiPJLAG25E3ZRZMzcFZeQ+h8CI= +cloud.google.com/go/compute/metadata v0.2.3 h1:mg4jlk7mCAj6xXp9UJ4fjI9VUI5rubuGBW5aJ7UnBMY= +cloud.google.com/go/compute/metadata v0.2.3/go.mod h1:VAV5nSsACxMJvgaAuX6Pk2AawlZn8kiOGuCv6gTkwuA= +github.com/Azure/azure-sdk-for-go/sdk/azcore v1.9.1 h1:lGlwhPtrX6EVml1hO0ivjkUxsSyl4dsiw9qcA1k/3IQ= +github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.5.1 h1:sO0/P7g68FrryJzljemN+6GTssUXdANk6aJ7T1ZxnsQ= +github.com/Azure/azure-sdk-for-go/sdk/internal v1.5.1 h1:6oNBlSdi1QqM1PNW7FPA6xOGA5UNsXnkaYZz9vdPGhA= +github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/compute/armcompute/v5 v5.4.0 h1:QfV5XZt6iNa2aWMAt96CZEbfJ7kgG/qYIpq465Shr5E= +github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/network/armnetwork/v4 v4.3.0 h1:bXwSugBiSbgtz7rOtbfGf+woewp4f06orW9OP5BjHLA= +github.com/AzureAD/microsoft-authentication-library-for-go v1.2.1 h1:DzHpqpoJVaCgOUdVHxE8QB52S6NiVdDQvGlny1qvPqA= +github.com/Code-Hex/go-generics-cache v1.3.1 h1:i8rLwyhoyhaerr7JpjtYjJZUcCbWOdiYO3fZXLiEC4g= +github.com/KimMachineGun/automemlimit v0.5.0 h1:BeOe+BbJc8L5chL3OwzVYjVzyvPALdd5wxVVOWuUZmQ= +github.com/Microsoft/go-winio v0.6.1 h1:9/kr64B9VUZrLm5YYwbGtUJnMgqWVOdUAXu6Migciow= +github.com/alecthomas/kingpin/v2 v2.4.0 h1:f48lwail6p8zpO1bC4TxtqACaGqHYA22qkHjHpqDjYY= +github.com/alecthomas/units v0.0.0-20231202071711-9a357b53e9c9 h1:ez/4by2iGztzR4L0zgAOR8lTQK9VlyBVVd7G4omaOQs= +github.com/antihax/optional v1.0.0 h1:xK2lYat7ZLaVVcIuj82J8kIro4V6kDe0AUDFboUCwcg= +github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= +github.com/armon/go-metrics v0.4.1 h1:hR91U9KYmb6bLBYLQjyM+3j+rcd/UhE+G78SFnF8gJA= +github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2 h1:DklsrG3dyBCFEj5IhUbnKptjxatkF07cF2ak3yi77so= +github.com/aws/aws-sdk-go v1.50.0 h1:HBtrLeO+QyDKnc3t1+5DR1RxodOHCGr8ZcrHudpv7jI= +github.com/bboreham/go-loser v0.0.0-20230920113527-fcc2c21820a3 h1:6df1vn4bBlDDo4tARvBm7l6KA9iVMnE3NWizDeWSrps= +github.com/census-instrumentation/opencensus-proto v0.4.1 h1:iKLQ0xPNFxR/2hzXZMrBo8f1j86j5WHzznCCQxV/b8g= +github.com/census-instrumentation/opencensus-proto v0.4.1/go.mod h1:4T9NM4+4Vw91VeyqjLS6ao50K5bOcLKN6Q42XnYaRYw= +github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44= +github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/cilium/ebpf v0.11.0 h1:V8gS/bTCCjX9uUnkUFUpPsksM8n1lXBAvHcpiFk1X2Y= +github.com/cncf/udpa/go v0.0.0-20220112060539-c52dc94e7fbe h1:QQ3GSy+MqSHxm/d8nCtnAiZdYFd45cYZPs8vOOIYKfk= +github.com/cncf/udpa/go v0.0.0-20220112060539-c52dc94e7fbe/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI= +github.com/cncf/xds/go v0.0.0-20230607035331-e9ce68804cb4 h1:/inchEIKaYC1Akx+H+gqO04wryn5h75LSazbRlnya1k= +github.com/cncf/xds/go v0.0.0-20231109132714-523115ebc101 h1:7To3pQ+pZo0i3dsWEbinPNFs5gPSBOsJtx3wTT94VBY= +github.com/cncf/xds/go v0.0.0-20231109132714-523115ebc101/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/containerd/cgroups/v3 v3.0.3 h1:S5ByHZ/h9PMe5IOQoN7E+nMc2UcLEM/V48DGDJ9kip0= +github.com/containerd/log v0.1.0 h1:TCJt7ioM2cr/tfR8GPbGf9/VRAX8D2B4PjzCpfX540I= +github.com/coreos/go-systemd/v22 v22.5.0 h1:RrqgGjYQKalulkV8NGVIfkXQf6YYmOyiJKk8iXXhfZs= +github.com/dennwc/varint v1.0.0 h1:kGNFFSSw8ToIy3obO/kKr8U9GZYUAxQEVuix4zfDWzE= +github.com/digitalocean/godo v1.108.0 h1:fWyMENvtxpCpva1UbKzOFnyAS04N1FNuBWWfPeTGquQ= +github.com/distribution/reference v0.5.0 h1:/FUIFXtfc/x2gpa5/VGfiGLuOIdYa1t65IKK2OFGvA0= +github.com/docker/docker v25.0.0+incompatible h1:g9b6wZTblhMgzOT2tspESstfw6ySZ9kdm94BLDKaZac= +github.com/docker/go-connections v0.4.0 h1:El9xVISelRB7BuFusrZozjnkIM5YnzCViNKohAFqRJQ= +github.com/docker/go-units v0.5.0 h1:69rxXcBk27SvSaaxTtLh/8llcHD8vYHT7WSdRZ/jvr4= +github.com/edsrzf/mmap-go v1.1.0 h1:6EUwBLQ/Mcr1EYLE4Tn1VdW1A4ckqCQWZBw8Hr0kjpQ= +github.com/emicklei/go-restful/v3 v3.11.0 h1:rAQeMHw1c7zTmncogyy8VvRZwtkmkZ4FxERmMY4rD+g= +github.com/envoyproxy/go-control-plane v0.11.1 h1:wSUXTlLfiAQRWs2F+p+EKOY9rUyis1MyGqJ2DIk5HpM= +github.com/envoyproxy/go-control-plane v0.11.1/go.mod h1:uhMcXKCQMEJHiAb0w+YGefQLaTEw+YhGluxZkrTmD0g= +github.com/envoyproxy/go-control-plane v0.12.0 h1:4X+VP1GHd1Mhj6IB5mMeGbLCleqxjletLK6K0rbxyZI= +github.com/envoyproxy/protoc-gen-validate v1.0.2 h1:QkIBuU5k+x7/QXPvPPnWXWlCdaBFApVqftFV6k087DA= +github.com/envoyproxy/protoc-gen-validate v1.0.2/go.mod h1:GpiZQP3dDbg4JouG/NNS7QWXpgx6x8QiMKdmN72jogE= +github.com/envoyproxy/protoc-gen-validate v1.0.4 h1:gVPz/FMfvh57HdSJQyvBtF00j8JU4zdyUgIUNhlgg0A= +github.com/evanphx/json-patch v5.6.0+incompatible h1:jBYDEEiFBPxA0v50tFdvOzQQTCvpL6mnFh5mB2/l16U= +github.com/facette/natsort v0.0.0-20181210072756-2cd4dd1e2dcb h1:IT4JYU7k4ikYg1SCxNI1/Tieq/NFvh6dzLdgi7eu0tM= +github.com/fatih/color v1.15.0 h1:kOqh6YHBtK8aywxGerMG2Eq3H6Qgoqeo13Bk2Mv/nBs= +github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA= +github.com/ghodss/yaml v1.0.0 h1:wQHKEahhL6wmXdzwWG11gIVCkOv05bNOh+Rxn0yngAk= +github.com/go-kit/kit v0.12.0 h1:e4o3o3IsBfAKQh5Qbbiqyfu97Ku7jrO/JbohvztANh4= +github.com/go-kit/log v0.2.1 h1:MRVx0/zhvdseW+Gza6N9rVzU/IVzaeE1SFI4raAhmBU= +github.com/go-logfmt/logfmt v0.6.0 h1:wGYYu3uicYdqXVgoYbvnkrPVXkuLM1p1ifugDMEdRi4= +github.com/go-openapi/analysis v0.21.4 h1:ZDFLvSNxpDaomuCueM0BlSXxpANBlFYiBvr+GXrvIHc= +github.com/go-openapi/errors v0.21.0 h1:FhChC/duCnfoLj1gZ0BgaBmzhJC2SL/sJr8a2vAobSY= +github.com/go-openapi/jsonpointer v0.20.0 h1:ESKJdU9ASRfaPNOPRx12IUyA1vn3R9GiE3KYD14BXdQ= +github.com/go-openapi/jsonreference v0.20.2 h1:3sVjiK66+uXK/6oQ8xgcRKcFgQ5KXa2KvnJRumpMGbE= +github.com/go-openapi/loads v0.21.2 h1:r2a/xFIYeZ4Qd2TnGpWDIQNcP80dIaZgf704za8enro= +github.com/go-openapi/spec v0.20.9 h1:xnlYNQAwKd2VQRRfwTEI0DcK+2cbuvI/0c7jx3gA8/8= +github.com/go-openapi/strfmt v0.22.0 h1:Ew9PnEYc246TwrEspvBdDHS4BVKXy/AOVsfqGDgAcaI= +github.com/go-openapi/swag v0.22.4 h1:QLMzNJnMGPRNDCbySlcj1x01tzU8/9LTTL9hZZZogBU= +github.com/go-openapi/validate v0.22.1 h1:G+c2ub6q47kfX1sOBLwIQwzBVt8qmOAARyo/9Fqs9NU= +github.com/go-resty/resty/v2 v2.11.0 h1:i7jMfNOJYMp69lq7qozJP+bjgzfAzeOhuGlyDrqxT/8= +github.com/go-zookeeper/zk v1.0.3 h1:7M2kwOsc//9VeeFiPtf+uSJlVpU66x9Ba5+8XK7/TDg= +github.com/godbus/dbus/v5 v5.0.4 h1:9349emZab16e7zQvpmsbtjc18ykshndd8y2PG3sgJbA= +github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q= +github.com/golang-jwt/jwt/v5 v5.2.0 h1:d/ix8ftRUorsN+5eMIlF4T6J8CAt9rch3My2winC1Jw= +github.com/golang/glog v1.1.2 h1:DVjP2PbBOzHyzA+dn3WhHIq4NdVu3Q+pvivFICf/7fo= +github.com/golang/glog v1.1.2/go.mod h1:zR+okUeTbrL6EL3xHUDxZuEtGv04p5shwip1+mL/rLQ= +github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da h1:oI5xCqsCo564l8iNU+DwB5epxmsaqB+rhGL0m5jtYqE= +github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM= +github.com/google/gnostic-models v0.6.8 h1:yo/ABAfM5IMRsS1VnXjTBvUb61tFIHozhlYvRgGre9I= +github.com/google/go-querystring v1.1.0 h1:AnCroh3fv4ZBgVIf1Iwtovgjaw/GiKJo8M8yD/fhyJ8= +github.com/google/gofuzz v1.2.0 h1:xRy4A+RhZaiKjJ1bPfwQ8sedCA+YS2YcCHW6ec7JMi0= +github.com/google/pprof v0.0.0-20240117000934-35fc243c5815 h1:WzfWbQz/Ze8v6l++GGbGNFZnUShVpP/0xffCPLL+ax8= +github.com/google/s2a-go v0.1.7 h1:60BLSyTrOV4/haCDW4zb1guZItoSq8foHCXrAnjBo/o= +github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I= +github.com/google/uuid v1.3.1 h1:KjJaJ9iWZ3jOFZIf1Lqf4laDRCasjl0BCmnEGxkdLb4= +github.com/google/uuid v1.4.0 h1:MtMxsa51/r9yyhkyLsVeVt0B+BGQZzpQiTQ4eHZ8bc4= +github.com/google/uuid v1.4.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/google/uuid v1.5.0 h1:1p67kYwdtXjb0gL0BPiP1Av9wiZPo5A8z2cWkTZ+eyU= +github.com/googleapis/enterprise-certificate-proxy v0.3.2 h1:Vie5ybvEvT75RniqhfFxPRy3Bf7vr3h0cechB90XaQs= +github.com/googleapis/gax-go/v2 v2.12.0 h1:A+gCJKdRfqXkr+BIRGtZLibNXf0m1f9E4HG56etFpas= +github.com/gophercloud/gophercloud v1.8.0 h1:TM3Jawprb2NrdOnvcHhWJalmKmAmOGgfZElM/3oBYCk= +github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc= +github.com/hashicorp/consul/api v1.27.0 h1:gmJ6DPKQog1426xsdmgk5iqDyoRiNc+ipBdJOqKQFjc= +github.com/hashicorp/cronexpr v1.1.2 h1:wG/ZYIKT+RT3QkOdgYc+xsKWVRgnxJ1OJtjjy84fJ9A= +github.com/hashicorp/errwrap v1.1.0 h1:OxrOeh75EUXMY8TBjag2fzXGZ40LB6IKw45YeGUDY2I= +github.com/hashicorp/go-cleanhttp v0.5.2 h1:035FKYIWjmULyFRBKPs8TBQoi0x6d9G4xc9neXJWAZQ= +github.com/hashicorp/go-hclog v1.5.0 h1:bI2ocEMgcVlz55Oj1xZNBsVi900c7II+fWDyV9o+13c= +github.com/hashicorp/go-immutable-radix v1.3.1 h1:DKHmCUm2hRBK510BaiZlwvpD40f8bJFeZnpfm2KLowc= +github.com/hashicorp/go-multierror v1.1.1 h1:H5DkEtf6CXdFp0N0Em5UCwQpXMWke8IA0+lD48awMYo= +github.com/hashicorp/go-retryablehttp v0.7.4 h1:ZQgVdpTdAL7WpMIwLzCfbalOcSUdkDZnpUv3/+BxzFA= +github.com/hashicorp/go-rootcerts v1.0.2 h1:jzhAVGtqPKbwpyCPELlgNWhE1znq+qwJtW5Oi2viEzc= +github.com/hashicorp/go-version v1.6.0 h1:feTTfFNnjP967rlCxM/I9g701jU+RN74YKx2mOkIeek= +github.com/hashicorp/golang-lru v0.6.0 h1:uL2shRDx7RTrOrTCUZEGP/wJUFiUI8QT6E7z5o8jga4= +github.com/hashicorp/nomad/api v0.0.0-20230721134942-515895c7690c h1:Nc3Mt2BAnq0/VoLEntF/nipX+K1S7pG+RgwiitSv6v0= +github.com/hashicorp/serf v0.10.1 h1:Z1H2J60yRKvfDYAOZLd2MU0ND4AH/WDz7xYHDWQsIPY= +github.com/hetznercloud/hcloud-go/v2 v2.6.0 h1:RJOA2hHZ7rD1pScA4O1NF6qhkHyUdbbxjHgFNot8928= +github.com/imdario/mergo v0.3.16 h1:wwQJbIsHYGMUyLSPrEq1CT16AhnhNJQ51+4fdHUnCl4= +github.com/ionos-cloud/sdk-go/v6 v6.1.11 h1:J/uRN4UWO3wCyGOeDdMKv8LWRzKu6UIkLEaes38Kzh8= +github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg= +github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8HmY= +github.com/jpillora/backoff v1.0.0 h1:uvFg412JmmHBHw7iwprIxkPMI+sGQ4kzOWsMeHnm2EA= +github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= +github.com/julienschmidt/httprouter v1.3.0 h1:U0609e9tgbseu3rBINet9P48AI/D3oJs4dN7jwJOQ1U= +github.com/kolo/xmlrpc v0.0.0-20220921171641-a4b6fa1dd06b h1:udzkj9S/zlT5X367kqJis0QP7YMxobob6zhzq6Yre00= +github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= +github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= +github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= +github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc= +github.com/linode/linodego v1.27.1 h1:KoQm5g2fppw8qIClJqUEL0yKH0+f+7te3Mewagb5QKE= +github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= +github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA= +github.com/mattn/go-isatty v0.0.19 h1:JITubQf0MOLdlGRuRq+jtsDlekdYPia9ZFsB8h/APPA= +github.com/miekg/dns v1.1.58 h1:ca2Hdkz+cDg/7eNF6V56jjzuZ4aCAE+DbVkILdQWG/4= +github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y= +github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY= +github.com/moby/term v0.0.0-20210619224110-3f7ff695adc6 h1:dcztxKSvZ4Id8iPpHERQBbIJfabdt4wUm5qy3wOL2Zc= +github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= +github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M= +github.com/morikuni/aec v1.0.0 h1:nP9CBfwrvYnBRgY6qfDQkygYDmYwOilePFkwzv4dU8A= +github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA= +github.com/mwitkow/go-conntrack v0.0.0-20190716064945-2f068394615f h1:KUppIJq7/+SVif2QVs3tOP0zanoHgBEVAwHxUSIzRqU= +github.com/nsf/jsondiff v0.0.0-20230430225905-43f6cf3098c1 h1:dOYG7LS/WK00RWZc8XGgcUTlTxpp3mKhdR2Q9z9HbXM= +github.com/oklog/run v1.1.0 h1:GEenZ1cK0+q0+wsJew9qUg/DyD8k3JzYsZAi5gYi2mA= +github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4= +github.com/opencontainers/go-digest v1.0.0 h1:apOUWs51W5PlhuyGyz9FCeeBIOUDA/6nW8Oi/yOhh5U= +github.com/opencontainers/image-spec v1.0.2 h1:9yCKha/T5XdGtO0q9Q9a6T5NUCsTn/DrBg0D7ufOcFM= +github.com/opencontainers/runtime-spec v1.0.2 h1:UfAcuLBJB9Coz72x1hgl8O5RVzTdNiaglX6v2DM6FI0= +github.com/ovh/go-ovh v1.4.3 h1:Gs3V823zwTFpzgGLZNI6ILS4rmxZgJwJCz54Er9LwD0= +github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 h1:onHthvaw9LFnH4t2DcNVpwGmV9E1BkGknEliJkfwQj0= +github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c h1:+mdjkGKdHQG3305AYmdv1U2eRNDiU2ErMBj1gwrq8eQ= +github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4= +github.com/prometheus/alertmanager v0.26.0 h1:uOMJWfIwJguc3NaM3appWNbbrh6G/OjvaHMk22aBBYc= +github.com/prometheus/common/assets v0.2.0 h1:0P5OrzoHrYBOSM1OigWL3mY8ZvV2N4zIE/5AahrSrfM= +github.com/prometheus/common/sigv4 v0.1.0 h1:qoVebwtwwEhS85Czm2dSROY5fTo2PAPEVdDeppTwGX4= +github.com/prometheus/exporter-toolkit v0.11.0 h1:yNTsuZ0aNCNFQ3aFTD2uhPOvr4iD7fdBvKPAEGkNf+g= +github.com/rogpeppe/fastuuid v1.2.0 h1:Ppwyp6VYCF1nvBTXL3trRso7mXMlRrw9ooo375wvi2s= +github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ= +github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M= +github.com/rogpeppe/go-internal v1.11.0/go.mod h1:ddIwULY96R17DhadqLgMfk9H9tvdUzkipdSkR5nkCZA= +github.com/scaleway/scaleway-sdk-go v1.0.0-beta.22 h1:wJrcTdddKOI8TFxs8cemnhKP2EmKy3yfUKHj3ZdfzYo= +github.com/shurcooL/httpfs v0.0.0-20230704072500-f1e31cf0ba5c h1:aqg5Vm5dwtvL+YgDpBcK1ITf3o96N/K7/wsRXQnUTEs= +github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ= +github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA= +github.com/stretchr/objx v0.1.0 h1:4G4v2dO3VZwixGIRoQ5Lfboy6nUhCyYzaqnIAPPhYs4= +github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c= +github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/vultr/govultr/v2 v2.17.2 h1:gej/rwr91Puc/tgh+j33p/BLR16UrIPnSr+AIwYWZQs= +github.com/xhit/go-str2duration/v2 v2.1.0 h1:lxklc02Drh6ynqX+DdPyp5pCKLUQpRT8bp8Ydu2Bstc= +go.mongodb.org/mongo-driver v1.13.1 h1:YIc7HTYsKndGK4RFzJ3covLz1byri52x0IoMB0Pt/vk= +go.opencensus.io v0.24.0 h1:y73uSU6J157QMP2kn2r30vwW1A2W2WFwSCGnAVxeaD0= +go.opentelemetry.io/collector/featuregate v1.0.1 h1:ok//hLSXttBbyu4sSV1pTx1nKdr5udSmrWy5sFMIIbM= +go.opentelemetry.io/collector/pdata v1.0.1 h1:dGX2h7maA6zHbl5D3AsMnF1c3Nn+3EUftbVCLzeyNvA= +go.opentelemetry.io/collector/semconv v0.93.0 h1:eBlMcVNTwYYsVdAsCVDs4wvVYs75K1xcIDpqj16PG4c= +go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.22.0 h1:H2JFgRcGiyHg7H7bwcwaQJYrNFqCqrbTQ8K4p1OvDu8= +go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE= +go.uber.org/automaxprocs v1.5.3 h1:kWazyxZUrS3Gs4qUpbwo5kEIMGe/DAvi5Z4tl2NW4j8= +go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0= +golang.org/x/crypto v0.11.0 h1:6Ewdq3tDic1mg5xRO4milcWCfMVQhI4NkqWWvqejpuA= +golang.org/x/crypto v0.14.0 h1:wBqGXzWJW6m1XrIKlAH0Hs1JJ7+9KBwnIO8v66Q9cHc= +golang.org/x/crypto v0.15.0 h1:frVn1TEaCEaZcn3Tmd7Y2b5KKPaZ+I32Q2OA3kYp5TA= +golang.org/x/crypto v0.18.0 h1:PGVlW0xEltQnzFZ55hkuX5+KLyrMYhHld1YHO4AKcdc= +golang.org/x/crypto v0.18.0/go.mod h1:R0j02AL6hcrfOiy9T4ZYp/rcWeMxM3L6QYxlOuEG1mg= +golang.org/x/mod v0.8.0 h1:LUYupSeNrTNCGzR/hVBk2NHZO4hXcVaW1k4Qx7rjPx8= +golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs= +golang.org/x/mod v0.14.0 h1:dGoOF9QVLYng8IHTm7BAyWqCqSheQ5pYWGhzW00YJr0= +golang.org/x/oauth2 v0.10.0 h1:zHCpF2Khkwy4mMB4bv0U37YtJdTGW8jI0glAApi0Kh8= +golang.org/x/oauth2 v0.11.0 h1:vPL4xzxBM4niKCW6g9whtaWVXTJf1U5e4aZxxFx/gbU= +golang.org/x/oauth2 v0.12.0 h1:smVPGxink+n1ZI5pkQa8y6fZT0RW0MgCO5bFpepy4B4= +golang.org/x/oauth2 v0.13.0 h1:jDDenyj+WgFtmV3zYVoi8aE2BwtXFLWOA67ZfNWftiY= +golang.org/x/oauth2 v0.14.0 h1:P0Vrf/2538nmC0H+pEQ3MNFRRnVR7RlqyVw+bvm26z0= +golang.org/x/oauth2 v0.14.0/go.mod h1:lAtNWgaWfL4cm7j2OV8TxGi9Qb7ECORx8DktCY74OwM= +golang.org/x/oauth2 v0.16.0 h1:aDkGMBSYxElaoP81NpoUoz2oo2R2wHdZpGToUxfyQrQ= +golang.org/x/sync v0.3.0 h1:ftCYgMx6zT/asHUrPw8BLLscYtGznsLAnjq5RH9P66E= +golang.org/x/sync v0.5.0 h1:60k92dhOjHxJkrqnwsfl8KuaHbn/5dl0lUPUklKo3qE= +golang.org/x/sync v0.5.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.6.0 h1:5BMeUDZ7vkXGfEr1x9B4bRcTH4lpkTkpdh0T/J+qjbQ= +golang.org/x/term v0.10.0 h1:3R7pNqamzBraeqj/Tj8qt1aQ2HpmlC+Cx/qL/7hn4/c= +golang.org/x/term v0.13.0 h1:bb+I9cTfFazGW51MZqBVmZy7+JEJMouUHTUSKVQLBek= +golang.org/x/term v0.14.0 h1:LGK9IlZ8T9jvdy6cTdfKUCltatMFOehAQo9SRC46UQ8= +golang.org/x/term v0.16.0 h1:m+B6fahuftsE9qjo0VWp2FW0mB3MTJvR0BaMQrq0pmE= +golang.org/x/term v0.16.0/go.mod h1:yn7UURbUtPyrVJPGPq404EukNFxcm/foM+bV/bfcDsY= +golang.org/x/time v0.5.0 h1:o7cqy6amK/52YcAKIPlM3a+Fpj35zvRj2TP+e1xFSfk= +golang.org/x/tools v0.6.0 h1:BOw41kyTf3PuCW1pVQf8+Cyg8pMlkYB1oo9iJ6D/lKM= +golang.org/x/tools v0.6.0/go.mod h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU= +golang.org/x/tools v0.17.0 h1:FvmRgNOcs3kOa+T20R1uhfP9F6HgG2mfxDv1vrx1Htc= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= +google.golang.org/api v0.157.0 h1:ORAeqmbrrozeyw5NjnMxh7peHO0UzV4wWYSwZeCUb20= +google.golang.org/appengine v1.6.7 h1:FZR1q0exgwxzPzp/aF+VccGrSfxfPpkBqjIIEq3ru6c= +google.golang.org/appengine v1.6.8 h1:IhEN5q69dyKagZPYMSdIjS2HqprW324FRQZJcGqPAsM= +google.golang.org/appengine v1.6.8/go.mod h1:1jJ3jBArFh5pcgW8gCtRJnepW8FzD1V44FJffLiz/Ds= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= +gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc= +gopkg.in/ini.v1 v1.67.0 h1:Dgnx+6+nfE+IfzjUEISNeydPJh9AXNNsWbGP9KzCsOA= +gotest.tools/v3 v3.0.3 h1:4AuOwCGf4lLR9u3YOe2awrHygurzhO/HeQ6laiA6Sx0= +k8s.io/api v0.28.6 h1:yy6u9CuIhmg55YvF/BavPBBXB+5QicB64njJXxVnzLo= +k8s.io/apimachinery v0.28.6 h1:RsTeR4z6S07srPg6XYrwXpTJVMXsjPXn0ODakMytSW0= +k8s.io/client-go v0.28.6 h1:Gge6ziyIdafRchfoBKcpaARuz7jfrK1R1azuwORIsQI= +k8s.io/klog v1.0.0 h1:Pt+yjF5aB1xDSVbau4VsWe+dQNzA0qv1LlXdC2dF6Q8= +k8s.io/klog/v2 v2.120.1 h1:QXU6cPEOIslTGvZaXvFWiP9VKyeet3sawzTOvdXb4Vw= +k8s.io/kube-openapi v0.0.0-20231010175941-2dd684a91f00 h1:aVUu9fTY98ivBPKR9Y5w/AuzbMm96cd3YHRTU83I780= +k8s.io/utils v0.0.0-20230726121419-3b25d923346b h1:sgn3ZU783SCgtaSJjpcVVlRqd6GSnlTLKgpAAttJvpI= +sigs.k8s.io/json v0.0.0-20221116044647-bc3834ca7abd h1:EDPBXCAspyGV4jQlpZSudPeMmr1bNJefnuqLsRAsHZo= +sigs.k8s.io/structured-merge-diff/v4 v4.4.1 h1:150L+0vs/8DA78h1u02ooW1/fFq/Lwr+sGiqlzvrtq4= +sigs.k8s.io/yaml v1.3.0 h1:a2VclLzOGrwOHDiV8EfBGhvjHvP46CtW5j6POvhYGGo= diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/datasources/pyroscope.yml b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/datasources/pyroscope.yml new file mode 100644 index 0000000000..1ac5fa535b --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/datasources/pyroscope.yml @@ -0,0 +1,14 @@ +--- +apiVersion: 1 +datasources: + - uid: local-pyroscope + type: grafana-pyroscope-datasource + name: Pyroscope + url: http://pyroscope:4040 + jsonData: + keepCookies: [pyroscope_git_session] + # Uncomment these if using with Grafana Cloud + # basicAuth: true + # basicAuthUser: '123456' + # secureJsonData: + # basicAuthPassword: PASSWORD diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/plugins/explore-profiles.yml b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/plugins/explore-profiles.yml new file mode 100644 index 0000000000..0d1302202e --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/grafana-provisioning/plugins/explore-profiles.yml @@ -0,0 +1,11 @@ +--- +apiVersion: 1 +apps: + - type: grafana-pyroscope-app + jsonData: + backendUrl: http://pyroscope:4040 + # uncomment this if sending data to Grafana Cloud + # basicAuthUser: '123456' + secureJsonData: + # uncomment this if sending data to Grafana Cloud + # basicAuthPassword: PASSWORD diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/load.js b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/load.js new file mode 100644 index 0000000000..6553e9dc7a --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/load.js @@ -0,0 +1,25 @@ +import http from 'k6/http'; +import { check } from 'k6'; +import pyroscope from 'https://jslib.k6.io/http-instrumentation-pyroscope/1.0.0/index.js'; + +pyroscope.instrumentHTTP(); + +export let options = { + vus: 3, + duration: '1m', +}; + +export default function () { + const vehicles = [ + 'car', + 'scooter', + 'bike', + ]; + + for (const v of vehicles) { + const req = http.get(`http://localhost:5001/${v}`); + check(req, { + 'status is 200': (r) => r.status === 200, + }); + } +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/loadgen.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/loadgen.go new file mode 100644 index 0000000000..f2a2050a8c --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/loadgen.go @@ -0,0 +1,143 @@ +package main + +import ( + "context" + "fmt" + "log" + "math/rand" + "net/http" + "os" + "os/signal" + "syscall" + "time" + + otelpyroscope "github.com/grafana/otel-profiling-go" + "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" + "go.opentelemetry.io/otel/propagation" + + "rideshare/rideshare" + "rideshare/utility" +) + +var vehicles = []string{ + "bike", + "scooter", + "car", +} + +var client *http.Client + +func main() { + c := rideshare.ReadConfig() + c.AppName = "load-generator" + + url, ok := os.LookupEnv("RIDESHARE_URL") + if !ok { + log.Fatalf("RIDESHARE_URL is not set") + } + + vus := utility.EnvIntOrDefault("VUS", 1) + jitter := utility.EnvDurationOrDefault("JITTER", 100*time.Millisecond) + sleep := utility.EnvDurationOrDefault("SLEEP", 100*time.Millisecond) + + // Configure profiler. + p, err := rideshare.Profiler(c) + if err != nil { + log.Fatalf("failed to initialize profiler: %v\n", err) + } + defer func() { + _ = p.Stop() + }() + + // Configure tracing. + tp, err := rideshare.TracerProvider(c) + if err != nil { + log.Fatalf("failed to initialize profiler: %v\n", err) + } + + // Set the Tracer Provider and the W3C Trace Context propagator as globals. + // We wrap the tracer provider to also annotate goroutines with Span ID so + // that pprof would add corresponding labels to profiling samples. + otel.SetTracerProvider(otelpyroscope.NewTracerProvider(tp)) + + // Register the trace context and baggage propagators so data is propagated + // across services/processes. + otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator( + propagation.TraceContext{}, + propagation.Baggage{}, + )) + + client = &http.Client{ + Transport: otelhttp.NewTransport(http.DefaultTransport), + } + + defer func() { + _ = tp.Shutdown(context.Background()) + }() + + doneChs := make([]chan struct{}, vus) + sig := make(chan os.Signal, 1) + signal.Notify(sig, syscall.SIGTERM, syscall.SIGINT) + + for i := 0; i < vus; i++ { + doneChs[i] = make(chan struct{}) + + go func(done <-chan struct{}) { + for { + select { + case <-done: + return + default: + err := sendThrottledRequest(context.Background(), url, sleep, jitter) + if err != nil { + log.Printf("failed to send request to %s: %v", url, err) + } + } + } + }(doneChs[i]) + } + + <-sig + for _, done := range doneChs { + close(done) + } +} + +func sendThrottledRequest(ctx context.Context, baseURL string, sleep time.Duration, jitter time.Duration) error { + ctx, span := otel.GetTracerProvider().Tracer("").Start(ctx, "SendRequest") + defer span.End() + + vehicle := vehicles[rand.Intn(len(vehicles))] + err := orderVehicle(ctx, baseURL, vehicle) + if err != nil { + return fmt.Errorf("failed to order %s: %v", vehicle, err) + } + + jitter = time.Duration(rand.Intn(int(jitter))) + time.Sleep(sleep + jitter) + return nil +} + +func orderVehicle(ctx context.Context, baseURL, vehicle string) error { + ctx, span := otel.GetTracerProvider().Tracer("").Start(ctx, "OrderVehicle") + defer span.End() + + span.SetAttributes(attribute.String("vehicle", vehicle)) + url := fmt.Sprintf("%s/%s", baseURL, vehicle) + log.Printf("requesting %s", url) + + req, err := http.NewRequestWithContext(ctx, "GET", url, nil) + if err != nil { + return err + } + + resp, err := client.Do(req) + if err != nil { + return err + } + + _ = resp.Body.Close() + return nil +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/main.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/main.go new file mode 100644 index 0000000000..e77afe055d --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/main.go @@ -0,0 +1,143 @@ +package main + +import ( + "context" + "fmt" + "log" + "net/http" + "os" + + "rideshare/bike" + "rideshare/car" + "rideshare/rideshare" + "rideshare/scooter" + "rideshare/utility" + + otellogs "github.com/agoda-com/opentelemetry-logs-go" + otelpyroscope "github.com/grafana/otel-profiling-go" + "github.com/grafana/pyroscope-go/x/k6" + "go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/propagation" + sdktrace "go.opentelemetry.io/otel/sdk/trace" +) + +func bikeRoute(w http.ResponseWriter, r *http.Request) { + bike.OrderBike(r.Context(), 1) + w.Write([]byte("

Bike ordered

")) +} + +func scooterRoute(w http.ResponseWriter, r *http.Request) { + scooter.OrderScooter(r.Context(), 2) + w.Write([]byte("

Scooter ordered

")) +} + +func carRoute(w http.ResponseWriter, r *http.Request) { + car.OrderCar(r.Context(), 3) + w.Write([]byte("

Car ordered

")) +} + +func index(w http.ResponseWriter, r *http.Request) { + rideshare.Log.Print(r.Context(), "showing index") + result := "

environment vars:

" + for _, env := range os.Environ() { + result += env + "
" + } + w.Write([]byte(result)) +} + +func main() { + config := rideshare.ReadConfig() + + tp, _ := setupOTEL(config) + defer func() { + _ = tp.Shutdown(context.Background()) + }() + + p, err := rideshare.Profiler(config) + + if err != nil { + log.Fatalf("error starting pyroscope profiler: %v", err) + } + defer func() { + _ = p.Stop() + }() + + cleanup := utility.InitWorkerPool(config) + defer cleanup() + + rideshare.Log.Print(context.Background(), "started ride-sharing app") + + routes := []route{ + {"/", "IndexHandler", http.HandlerFunc(index)}, + {"/bike", "BikeHandler", http.HandlerFunc(bikeRoute)}, + {"/scooter", "ScooterHandler", http.HandlerFunc(scooterRoute)}, + {"/car", "CarHandler", http.HandlerFunc(carRoute)}, + } + + routes = applyOtelMiddleware(routes) + routes = applyK6Middleware(routes) + registerRoutes(http.DefaultServeMux, routes) + + addr := fmt.Sprintf(":%s", config.RideshareListenPort) + log.Fatal(http.ListenAndServe(addr, nil)) +} + +func setupOTEL(c rideshare.Config) (tp *sdktrace.TracerProvider, err error) { + tp, err = rideshare.TracerProvider(c) + if err != nil { + return nil, err + } + + lp, err := rideshare.LoggerProvider(c) + if err != nil { + return nil, err + } + otellogs.SetLoggerProvider(lp) + + const ( + instrumentationName = "otel/zap" + instrumentationVersion = "0.0.1" + ) + + // Set the Tracer Provider and the W3C Trace Context propagator as globals. + // We wrap the tracer provider to also annotate goroutines with Span ID so + // that pprof would add corresponding labels to profiling samples. + otel.SetTracerProvider(otelpyroscope.NewTracerProvider(tp)) + + // Register the trace context and baggage propagators so data is propagated across services/processes. + otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator( + propagation.TraceContext{}, + propagation.Baggage{}, + )) + + return tp, err +} + +type route struct { + Path string + Name string + Handler http.Handler +} + +func registerRoutes(mux *http.ServeMux, handlers []route) { + for _, handler := range handlers { + mux.Handle(handler.Path, handler.Handler) + } +} + +func applyOtelMiddleware(routes []route) []route { + for _, route := range routes { + route.Handler = otelhttp.NewHandler(route.Handler, route.Name) + } + return routes +} + +// applyK6Middleware adds the k6 instrumentation middleware to all routes. This +// enables the Pyroscope SDK to label the profiles with k6 test metadata. +func applyK6Middleware(routes []route) []route { + for _, route := range routes { + route.Handler = k6.LabelsFromBaggageHandler(route.Handler) + } + return routes +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/nginx.conf b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/nginx.conf new file mode 100644 index 0000000000..f92dcfc43a --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/nginx.conf @@ -0,0 +1,23 @@ +events {} + +http { + upstream backend_servers { + random; + + server us-east:5000; + server eu-north:5000; + server ap-south:5000; + } + + server { + listen 80; + + location / { + proxy_pass http://backend_servers/; + proxy_set_header Host $host; + proxy_set_header X-Real-IP $remote_addr; + proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; + proxy_set_header X-Forwarded-Proto $scheme; + } + } +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/rideshare/rideshare.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/rideshare/rideshare.go new file mode 100644 index 0000000000..c43b27fee9 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/rideshare/rideshare.go @@ -0,0 +1,279 @@ +package rideshare + +import ( + "context" + "encoding/base64" + "fmt" + "os" + "strconv" + "time" + + "github.com/agoda-com/opentelemetry-logs-go/exporters/otlp/otlplogs" + "github.com/agoda-com/opentelemetry-logs-go/exporters/otlp/otlplogs/otlplogshttp" + "github.com/agoda-com/opentelemetry-logs-go/exporters/stdout/stdoutlogs" + "github.com/agoda-com/opentelemetry-logs-go/logs" + sdklogs "github.com/agoda-com/opentelemetry-logs-go/sdk/logs" + "github.com/grafana/pyroscope-go" + "go.opentelemetry.io/otel/attribute" + "go.opentelemetry.io/otel/exporters/otlp/otlptrace" + "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp" + "go.opentelemetry.io/otel/exporters/stdout/stdouttrace" + "go.opentelemetry.io/otel/sdk/resource" + sdktrace "go.opentelemetry.io/otel/sdk/trace" + semconv "go.opentelemetry.io/otel/semconv/v1.20.0" + "go.opentelemetry.io/otel/trace" +) + +type loggerAdapter struct { + logger logs.Logger +} + +func (la *loggerAdapter) Print(ctx context.Context, msg string) { + severityNumber := logs.INFO + now := time.Now() + c := logs.LogRecordConfig{ + ObservedTimestamp: now, + Timestamp: &now, + SeverityNumber: &severityNumber, + Body: &msg, + } + + span := trace.SpanFromContext(ctx) + if spanID := span.SpanContext().SpanID(); spanID.IsValid() { + c.SpanId = &spanID + } + if traceID := span.SpanContext().TraceID(); traceID.IsValid() { + c.TraceId = &traceID + } + la.logger.Emit(logs.NewLogRecord(c)) +} + +func (la *loggerAdapter) Printf(ctx context.Context, format string, v ...interface{}) { + la.Print(ctx, fmt.Sprintf(format, v...)) +} + +var Log = &loggerAdapter{logger: nil} + +type Config struct { + AppName string + PyroscopeServerAddress string + PyroscopeAuthToken string // for OG pyroscope and cloudstorage + PyroscopeBasicAuthUser string // for grafana + PyroscopeBasicAuthPassword string // for grafana + + OTLPUrl string + OTLPInsecure bool + OTLPBasicAuthUser string + OTLPBasicAuthPassword string + OTLPTracesUrlPath string + + UseDebugTracer bool + UseDebugLogger bool + Tags map[string]string + + ParametersPoolSize int + ParametersPoolBufferSize int + RideshareListenPort string +} + +func ReadConfig() Config { + appName := os.Getenv("PYROSCOPE_APPLICATION_NAME") + if appName == "" { + appName = "ride-sharing-app" + } + hostname, err := os.Hostname() + if err != nil { + hostname = "unknown" + } + c := Config{ + AppName: appName, + PyroscopeServerAddress: os.Getenv("PYROSCOPE_SERVER_ADDRESS"), + PyroscopeBasicAuthUser: os.Getenv("PYROSCOPE_BASIC_AUTH_USER"), + PyroscopeBasicAuthPassword: os.Getenv("PYROSCOPE_BASIC_AUTH_PASSWORD"), + + OTLPUrl: os.Getenv("OTLP_URL"), + OTLPInsecure: os.Getenv("OTLP_INSECURE") == "1", + OTLPBasicAuthUser: os.Getenv("OTLP_BASIC_AUTH_USER"), + OTLPBasicAuthPassword: os.Getenv("OTLP_BASIC_AUTH_PASSWORD"), + OTLPTracesUrlPath: os.Getenv("OTLP_TRACES_URL_PATH"), + + UseDebugTracer: os.Getenv("DEBUG_TRACER") == "1", + UseDebugLogger: os.Getenv("DEBUG_LOGGER") == "1", + Tags: map[string]string{ + "region": os.Getenv("REGION"), + "hostname": hostname, + "service_git_ref": "HEAD", + "service_repository": "https://github.com/grafana/pyroscope", + "service_root_path": "examples/language-sdk-instrumentation/golang-push/rideshare", + }, + + ParametersPoolSize: envIntOrDefault("PARAMETERS_POOL_SIZE", 1000), + + // Internally, we represent this as buffer size in bytes, but to make it + // more readable from as an env var, we represent the env var value in + // kb. + ParametersPoolBufferSize: envIntOrDefault("PARAMETERS_POOL_BUFFER_SIZE_KB", 1000) * 1000, + + RideshareListenPort: os.Getenv("RIDESHARE_LISTEN_PORT"), + } + if c.RideshareListenPort == "" { + c.RideshareListenPort = "5000" + } + if c.AppName == "" { + c.AppName = "ride-sharing-app" + } + if c.PyroscopeServerAddress == "" { + c.PyroscopeServerAddress = "http://localhost:4040" + } + return c +} + +func basicAuth(username, password string) string { + auth := username + ":" + password + return base64.StdEncoding.EncodeToString([]byte(auth)) +} + +func newResource(c Config, extraAttrs ...attribute.KeyValue) *resource.Resource { + host, _ := os.Hostname() + + attrs := append([]attribute.KeyValue{ + semconv.ServiceNameKey.String(c.AppName), + semconv.CloudRegionKey.String(os.Getenv("REGION")), + semconv.HostName(host), + }, extraAttrs...) + return resource.NewWithAttributes( + semconv.SchemaURL, + // Note that ServiceNameKey attribute can include chars not allowed in Pyroscope + // application name, therefore it should be used carefully. + attrs..., + ) +} + +func LoggerProvider(c Config) (*sdklogs.LoggerProvider, error) { + if c.UseDebugLogger || c.OTLPUrl == "" { + consoleProvider, err := stdoutlogs.NewExporter(stdoutlogs.WithWriter(os.Stderr)) + if err != nil { + return nil, err + } + loggerProvider := sdklogs.NewLoggerProvider( + sdklogs.WithBatcher(consoleProvider), + sdklogs.WithResource(newResource(c)), + ) + Log.logger = loggerProvider.Logger( + "ride-share", + logs.WithInstrumentationVersion("0.0.1"), + logs.WithSchemaURL(semconv.SchemaURL), + ) + return loggerProvider, nil + } + + exporter, _ := otlplogs.NewExporter(context.Background(), otlplogs.WithClient(otlplogshttp.NewClient( + otlplogshttp.WithEndpoint(c.OTLPUrl), + otlplogshttp.WithURLPath("/otlp/v1/logs"), + otlplogshttp.WithHeaders(map[string]string{ + "Authorization": "Basic " + basicAuth(c.OTLPBasicAuthUser, c.OTLPBasicAuthPassword), + }), + ))) + + // tell loki to use host.name and cloud.region as labels + lokiHint := attribute.KeyValue{ + Key: attribute.Key("loki.resource.labels"), + Value: attribute.StringSliceValue([]string{ + string(semconv.CloudRegionKey.String("").Key), + string(semconv.ServiceNameKey.String("").Key), + string(semconv.HostName("").Key), + }), + } + + loggerProvider := sdklogs.NewLoggerProvider( + sdklogs.WithBatcher(exporter), + sdklogs.WithResource(newResource(c, lokiHint)), + ) + + Log.logger = loggerProvider.Logger( + "ride-share", + logs.WithInstrumentationVersion("0.0.1"), + logs.WithSchemaURL(semconv.SchemaURL), + ) + + return loggerProvider, nil +} + +func TracerProvider(c Config) (*sdktrace.TracerProvider, error) { + if c.OTLPUrl == "" { + return stdoutTracerProvider(c.UseDebugTracer) + } + + ctx := context.Background() + opts := []otlptracehttp.Option{otlptracehttp.WithEndpoint(c.OTLPUrl)} + if c.OTLPTracesUrlPath != "" { + opts = append(opts, otlptracehttp.WithURLPath(c.OTLPTracesUrlPath)) + } + + if c.OTLPInsecure { + opts = append(opts, otlptracehttp.WithInsecure()) + } + + if c.OTLPBasicAuthUser != "" { + opts = append(opts, otlptracehttp.WithHeaders(map[string]string{ + "Authorization": "Basic " + basicAuth(c.OTLPBasicAuthUser, c.OTLPBasicAuthPassword), + })) + } + + exp, err := otlptrace.New(ctx, otlptracehttp.NewClient(opts...)) + if err != nil { + return nil, err + } + + // Create a new tracer provider with a batch span processor and the otlp exporter. + tp2 := sdktrace.NewTracerProvider( + sdktrace.WithBatcher(exp), + sdktrace.WithResource(newResource(c)), + ) + + return tp2, nil +} + +func stdoutTracerProvider(debug bool) (*sdktrace.TracerProvider, error) { + if !debug { + return sdktrace.NewTracerProvider(), nil + } + + exp, err := stdouttrace.New(stdouttrace.WithPrettyPrint()) + if err != nil { + return nil, err + } + return sdktrace.NewTracerProvider(sdktrace.WithSpanProcessor(sdktrace.NewSimpleSpanProcessor(exp))), nil +} + +func Profiler(c Config) (*pyroscope.Profiler, error) { + config := pyroscope.Config{ + ApplicationName: c.AppName, + ServerAddress: c.PyroscopeServerAddress, + Logger: pyroscope.StandardLogger, + Tags: c.Tags, + } + if c.PyroscopeAuthToken != "" { + config.AuthToken = c.PyroscopeAuthToken + } else if c.PyroscopeBasicAuthUser != "" { + config.BasicAuthUser = c.PyroscopeBasicAuthUser + config.BasicAuthPassword = c.PyroscopeBasicAuthPassword + } + return pyroscope.Start(config) +} + +// envIntOrDefault looks up the environment variable key and returns the value +// as an int. +func envIntOrDefault(key string, fallback int) int { + s, ok := os.LookupEnv(key) + if !ok { + return fallback + } + + v, err := strconv.Atoi(s) + if err != nil { + return fallback + } + + return v +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/scooter/scooter.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/scooter/scooter.go new file mode 100644 index 0000000000..e6eb356526 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/scooter/scooter.go @@ -0,0 +1,12 @@ +package scooter + +import ( + "context" + "rideshare/rideshare" + "rideshare/utility" +) + +func OrderScooter(ctx context.Context, searchRadius int64) { + rideshare.Log.Printf(ctx, "ordering scooter, with searchRadius=%d", searchRadius) + utility.FindNearestVehicle(ctx, searchRadius, "scooter") +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/pool.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/pool.go new file mode 100644 index 0000000000..8a650eeba1 --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/pool.go @@ -0,0 +1,92 @@ +package utility + +import ( + "os" + "sync" + + "rideshare/rideshare" +) + +type workerPool struct { + poolLock *sync.Mutex + pool []chan struct{} + limit int + bufferSize int +} + +// Run a function using a pool. +func (c *workerPool) Run(fn func()) { + if os.Getenv("REGION") != "us-east" { + // Only leak memory for us-east. If not us-east, run the worker + // function in a blocking manner. + + fn() + return + } + + stop := make(chan struct{}, 1) + done := make(chan struct{}, 1) + + c.poolLock.Lock() + size := len(c.pool) + if c.limit != 0 && size >= c.limit { + // We're at max pool limit, reset the pool. + c.resetWithoutLock() + } + c.pool = append(c.pool, stop) + c.poolLock.Unlock() + + // Create a goroutine to run the function. It will write to done when the + // work is over, but won't clean up until it receives a signal from stop. + go c.doWork(fn, stop, done) + + // Block until the worker signals it's done. + <-done + close(done) +} + +// Closes the pool, cleaning up all resources. +func (c *workerPool) Close() { + c.poolLock.Lock() + defer c.poolLock.Unlock() + + c.resetWithoutLock() +} + +func (c *workerPool) resetWithoutLock() { + for _, c := range c.pool { + c <- struct{}{} + close(c) + } + c.pool = c.pool[:0] +} + +func (c *workerPool) doWork(fn func(), stop <-chan struct{}, done chan<- struct{}) { + buf := make([]byte, 0) + + // Do work. + fn() + + // Simulate the work in fn requiring some data to be added to a buffer. + for i := 0; i < c.bufferSize; i++ { + buf = append(buf, byte(i)) + } + + // Don't let the compiler optimize away the buf. + var _ = buf + + // Signal we're done working. + done <- struct{}{} + + // Block until we're told to clean up. + <-stop +} + +func newPool(c rideshare.Config) *workerPool { + return &workerPool{ + poolLock: &sync.Mutex{}, + pool: make([]chan struct{}, 0, c.ParametersPoolSize), + limit: c.ParametersPoolSize, + bufferSize: c.ParametersPoolBufferSize, + } +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/util.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/util.go new file mode 100644 index 0000000000..eb5660d5ac --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/util.go @@ -0,0 +1,35 @@ +package utility + +import ( + "os" + "strconv" + "time" +) + +func EnvIntOrDefault(name string, n int) int { + s, ok := os.LookupEnv(name) + if !ok { + return n + } + + v, err := strconv.Atoi(s) + if err != nil { + return n + } + + return v +} + +func EnvDurationOrDefault(name string, d time.Duration) time.Duration { + s, ok := os.LookupEnv(name) + if !ok { + return d + } + + v, err := time.ParseDuration(s) + if err != nil { + return d + } + + return v +} diff --git a/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/utility.go b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/utility.go new file mode 100644 index 0000000000..dbc0b64dcb --- /dev/null +++ b/examples/language-sdk-instrumentation/golang-push/rideshare-k6/utility/utility.go @@ -0,0 +1,75 @@ +package utility + +import ( + "context" + "os" + "time" + + "rideshare/rideshare" + + "github.com/grafana/pyroscope-go" + "go.opentelemetry.io/otel" + "go.opentelemetry.io/otel/attribute" +) + +const durationConstant = time.Duration(200 * time.Millisecond) + +var pool *workerPool + +// InitWorkPool initializes the worker pool and returns a clean up function. +func InitWorkerPool(c rideshare.Config) func() { + pool = newPool(c) + return pool.Close +} + +func mutexLock(n int64) { + var i int64 = 0 + + // start time is number of seconds since epoch + startTime := time.Now() + + // This changes the amplitude of cpu bars + for time.Since(startTime) < time.Duration(n*30)*durationConstant { + i++ + } +} + +func checkDriverAvailability(n int64) { + var i int64 = 0 + + // start time is number of seconds since epoch + startTime := time.Now() + + pool.Run(func() { + for time.Since(startTime) < time.Duration(n)*durationConstant { + i++ + } + }) + + // Every other minute this will artificially create make requests in eu-north region slow + // this is just for demonstration purposes to show how performance impacts show up in the + // flamegraph + force_mutex_lock := time.Now().Minute()%2 == 0 + if os.Getenv("REGION") == "eu-north" && force_mutex_lock { + mutexLock(n) + } +} + +func FindNearestVehicle(ctx context.Context, searchRadius int64, vehicle string) { + ctx, span := otel.GetTracerProvider().Tracer("").Start(ctx, "FindNearestVehicle") + span.SetAttributes(attribute.String("vehicle", vehicle)) + defer span.End() + + pyroscope.TagWrapper(ctx, pyroscope.Labels("vehicle", vehicle), func(ctx context.Context) { + var i int64 = 0 + + startTime := time.Now() + for time.Since(startTime) < time.Duration(searchRadius)*durationConstant { + i++ + } + + if vehicle == "car" { + checkDriverAvailability(searchRadius) + } + }) +}