wip: otlp implementation

Signed-off-by: Hank Donnay <[email protected]>

docker-compose.yaml

@@ -5,7 +5,7 @@ version: "3.7"
 x-anchors:
  go: &go-image quay.io/projectquay/golang:1.20
  grafana: &grafana-image docker.io/grafana/grafana:8.0.3
- jaeger: &jaeger-image docker.io/jaegertracing/all-in-one:1.26
+ jaeger: &jaeger-image docker.io/jaegertracing/all-in-one:1.47
  pgadmin: &pgadmin-image docker.io/dpage/pgadmin4:5.7
  postgres: &postgres-image docker.io/library/postgres:12
  prom: &prom-image docker.io/prom/prometheus:v2.30.2
@@ -14,7 +14,7 @@ x-anchors:
  rabbitmq: &rabbitmq-image docker.io/library/rabbitmq:3.11
  redis: &redis-image docker.io/library/redis:6.2
  skopeo: &skopeo-image quay.io/skopeo/stable:latest
- traefik: &traefik-image docker.io/library/traefik:v2.2
+ traefik: &traefik-image docker.io/library/traefik:v3.0
  clair-service: &clair-service
  image: *go-image
  depends_on:
@@ -98,6 +98,7 @@ services:
  image: *jaeger-image
  environment:
  QUERY_BASE_PATH: '/jaeger'
+ COLLECTOR_OTLP_ENABLED: 'true'
  prometheus:
  container_name: clair-prometheus
  profiles:

go.mod

@@ -27,19 +27,24 @@ require (
  go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.42.0
  go.opentelemetry.io/otel v1.16.0
  go.opentelemetry.io/otel/exporters/jaeger v1.16.0
+ go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.16.0
+ go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.16.0
+ go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.16.0
  go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.16.0
  go.opentelemetry.io/otel/sdk v1.16.0
  go.opentelemetry.io/otel/trace v1.16.0
  golang.org/x/net v0.11.0
  golang.org/x/sync v0.3.0
  golang.org/x/time v0.3.0
+ google.golang.org/grpc v1.55.0
  gopkg.in/square/go-jose.v2 v2.6.0
  gopkg.in/yaml.v3 v3.0.1
 )
 
 require (
  github.com/Masterminds/semver v1.5.0 // indirect
  github.com/beorn7/perks v1.0.1 // indirect
+ github.com/cenkalti/backoff/v4 v4.2.1 // indirect
  github.com/cespare/xxhash/v2 v2.2.0 // indirect
  github.com/containerd/stargz-snapshotter/estargz v0.14.3 // indirect
  github.com/cpuguy83/go-md2man/v2 v2.0.2 // indirect
@@ -54,6 +59,7 @@ require (
  github.com/go-logr/stdr v1.2.2 // indirect
  github.com/golang/mock v1.6.0 // indirect
  github.com/golang/protobuf v1.5.3 // indirect
+ github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0 // indirect
  github.com/jackc/chunkreader/v2 v2.0.1 // indirect
  github.com/jackc/pgio v1.0.0 // indirect
  github.com/jackc/pgpassfile v1.0.0 // indirect
@@ -86,13 +92,17 @@ require (
  github.com/ulikunitz/xz v0.5.11 // indirect
  github.com/vbatts/tar-split v0.11.3 // indirect
  github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect
+ go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.16.0 // indirect
  go.opentelemetry.io/otel/metric v1.16.0 // indirect
+ go.opentelemetry.io/proto/otlp v0.20.0 // indirect
  golang.org/x/crypto v0.10.0 // indirect
  golang.org/x/mod v0.11.0 // indirect
- golang.org/x/sys v0.9.0 // indirect
+ golang.org/x/sys v0.10.0 // indirect
  golang.org/x/text v0.10.0 // indirect
  golang.org/x/tools v0.10.0 // indirect
- google.golang.org/protobuf v1.30.0 // indirect
+ google.golang.org/genproto/googleapis/api v0.0.0-20230530153820-e85fd2cbaebc // indirect
+ google.golang.org/genproto/googleapis/rpc v0.0.0-20230530153820-e85fd2cbaebc // indirect
+ google.golang.org/protobuf v1.31.0 // indirect
  lukechampine.com/uint128 v1.2.0 // indirect
  modernc.org/cc/v3 v3.40.0 // indirect
  modernc.org/ccgo/v3 v3.16.13 // indirect
@@ -104,3 +114,5 @@ require (
  modernc.org/strutil v1.1.3 // indirect
  modernc.org/token v1.0.1 // indirect
 )
+
+replace github.com/quay/clair/config => ./config

go.sum

@@ -8,6 +8,8 @@ github.com/Masterminds/semver/v3 v3.1.1 h1:hLg3sBzpNErnxhQtUy/mmLR2I9foDujNK030I
 github.com/Masterminds/semver/v3 v3.1.1/go.mod h1:VPu/7SZ7ePZ3QOrcuXROw5FAcLl4a0cBrbBpGY/8hQs=
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
 github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
+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/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
 github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/cockroachdb/apd v1.1.0 h1:3LFP3629v+1aKXU5Q37mxmRxX/pIu1nijXydLShEq5I=
@@ -53,6 +55,7 @@ github.com/go-stomp/stomp/v3 v3.0.5/go.mod h1:ztzZej6T2W4Y6FlD+Tb5n7HQP3/O5UNQiu
 github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
 github.com/gofrs/uuid v4.0.0+incompatible h1:1SD/1F5pU8p29ybwgQSwpQk+mwdRrXCYuPhW6m+TnJw=
 github.com/gofrs/uuid v4.0.0+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRxnplIgP/c0N/04lM=
+github.com/golang/glog v1.1.0 h1:/d3pCKDPWNnvIWe0vVUpNP32qc8U3PDVxySP/y360qE=
 github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
 github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
 github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
@@ -71,6 +74,8 @@ github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbu
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
 github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0 h1:YBftPWNWd4WwGqtY2yeZL2ef8rHAxPBD8KFhJpmcqms=
+github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0/go.mod h1:YN5jB8ie0yfIUg6VvR9Kz84aCaG7AsGZnLjhHbUqwPg=
 github.com/jackc/chunkreader v1.0.0/go.mod h1:RT6O25fNZIuasFJRyZ4R/Y2BbhasbmZXF9QQ7T3kePo=
 github.com/jackc/chunkreader/v2 v2.0.0/go.mod h1:odVSm741yZoC3dpHEUXIqA9tQRhFrgOHwnPIn9lDKlk=
 github.com/jackc/chunkreader/v2 v2.0.1 h1:i+RDz65UE+mmpjTfyz0MoVTnzeYxroil2G82ki7MGG8=
@@ -187,8 +192,6 @@ github.com/pyroscope-io/godeltaprof v0.1.1 h1:+Mmi+b9gR3s/qufuQSxOBjyXZR1fmvS/C1
 github.com/pyroscope-io/godeltaprof v0.1.1/go.mod h1:psMITXp90+8pFenXkKIpNhrfmI9saQnPbba27VIaiQE=
 github.com/quay/alas v1.0.1 h1:MuFpGGXyZlDD7+F/hrnMZmzhS8P2bjRzX9DyGmyLA+0=
 github.com/quay/alas v1.0.1/go.mod h1:pseepSrG9pwry1joG7RO/RNRFJaWqiqx9qeoomeYwEk=
-github.com/quay/clair/config v1.3.0 h1:UqJIwvgHaWj6yTWrpVnYnlEIKcVYxJItlEF2EsCnw5s=
-github.com/quay/clair/config v1.3.0/go.mod h1:XrxQFjAt0W+TUk5GkkSjNPxu1QgfycdRJr/+GVqUxBw=
 github.com/quay/claircore v1.5.8 h1:qhrKx16xUOsA5in700bO1GWn8NjKTArNA5I6sohecqY=
 github.com/quay/claircore v1.5.8/go.mod h1:6vs3Bba+HsR+pkxf+2zGV5Eq707syf2eZElLvZK2ido=
 github.com/quay/claircore/toolkit v1.0.0 h1:FiAo/URPMa62D9KN0YhyK+ATObtXl4I8/Jsf69GEHYM=
@@ -264,6 +267,14 @@ go.opentelemetry.io/otel v1.16.0 h1:Z7GVAX/UkAXPKsy94IU+i6thsQS4nb7LviLpnaNeW8s=
 go.opentelemetry.io/otel v1.16.0/go.mod h1:vl0h9NUa1D5s1nv3A5vZOYWn8av4K8Ml6JDeHrT/bx4=
 go.opentelemetry.io/otel/exporters/jaeger v1.16.0 h1:YhxxmXZ011C0aDZKoNw+juVWAmEfv/0W2XBOv9aHTaA=
 go.opentelemetry.io/otel/exporters/jaeger v1.16.0/go.mod h1:grYbBo/5afWlPpdPZYhyn78Bk04hnvxn2+hvxQhKIQM=
+go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.16.0 h1:t4ZwRPU+emrcvM2e9DHd0Fsf0JTPVcbfa/BhTDF03d0=
+go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.16.0/go.mod h1:vLarbg68dH2Wa77g71zmKQqlQ8+8Rq3GRG31uc0WcWI=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.16.0 h1:cbsD4cUcviQGXdw8+bo5x2wazq10SKz8hEbtCRPcU78=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.16.0/go.mod h1:JgXSGah17croqhJfhByOLVY719k1emAXC8MVhCIJlRs=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.16.0 h1:TVQp/bboR4mhZSav+MdgXB8FaRho1RC8UwVn3T0vjVc=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.16.0/go.mod h1:I33vtIe0sR96wfrUcilIzLoA3mLHhRmz9S9Te0S3gDo=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.16.0 h1:iqjq9LAB8aK++sKVcELezzn655JnBNdsDhghU4G/So8=
+go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.16.0/go.mod h1:hGXzO5bhhSHZnKvrDaXB82Y9DRFour0Nz/KrBh7reWw=
 go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.16.0 h1:+XWJd3jf75RXJq29mxbuXhCXFDG3S3R4vBUeSI2P7tE=
 go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.16.0/go.mod h1:hqgzBPTf4yONMFgdZvL/bK42R/iinTyVQtiWihs3SZc=
 go.opentelemetry.io/otel/metric v1.16.0 h1:RbrpwVG1Hfv85LgnZ7+txXioPDoh6EdbZHo26Q3hqOo=
@@ -272,10 +283,13 @@ go.opentelemetry.io/otel/sdk v1.16.0 h1:Z1Ok1YsijYL0CSJpHt4cS3wDDh7p572grzNrBMiM
 go.opentelemetry.io/otel/sdk v1.16.0/go.mod h1:tMsIuKXuuIWPBAOrH+eHtvhTL+SntFtXF9QD68aP6p4=
 go.opentelemetry.io/otel/trace v1.16.0 h1:8JRpaObFoW0pxuVPapkgH8UhHQj+bJW8jJsCZEu5MQs=
 go.opentelemetry.io/otel/trace v1.16.0/go.mod h1:Yt9vYq1SdNz3xdjZZK7wcXv1qv2pwLkqr2QVwea0ef0=
+go.opentelemetry.io/proto/otlp v0.20.0 h1:BLOA1cZBAGSbRiNuGCCKiFrCdYB7deeHDeD1SueyOfA=
+go.opentelemetry.io/proto/otlp v0.20.0/go.mod h1:3QgjzPALBIv9pcknj2EXGPXjYPFdUh/RQfF8Lz3+Vnw=
 go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
 go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
 go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
 go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
+go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A=
 go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
 go.uber.org/multierr v1.3.0/go.mod h1:VgVr7evmIr6uPjLBxg28wmKNXyqE9akIJ5XnfpiKl+4=
 go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=
@@ -344,8 +358,8 @@ golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBc
 golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220906165534-d0df966e6959/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.9.0 h1:KS/R3tvhPqvJvwcKfnBHJwwthS11LRhmM5D59eEXa0s=
-golang.org/x/sys v0.9.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.10.0 h1:SqMFp9UcQJZa+pmYuAKjd9xq1f0j5rLcDIk0mj4qAsA=
+golang.org/x/sys v0.10.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
@@ -383,10 +397,17 @@ golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 google.golang.org/appengine v1.6.1/go.mod h1:i06prIuMbXzDqacNJfV5OdTW448YApPu5ww/cMBSeb0=
+google.golang.org/genproto v0.0.0-20230526203410-71b5a4ffd15e h1:Ao9GzfUMPH3zjVfzXG5rlWlk+Q8MXWKwWpwVQE1MXfw=
+google.golang.org/genproto/googleapis/api v0.0.0-20230530153820-e85fd2cbaebc h1:kVKPf/IiYSBWEWtkIn6wZXwWGCnLKcC8oWfZvXjsGnM=
+google.golang.org/genproto/googleapis/api v0.0.0-20230530153820-e85fd2cbaebc/go.mod h1:vHYtlOoi6TsQ3Uk2yxR7NI5z8uoV+3pZtR4jmHIkRig=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20230530153820-e85fd2cbaebc h1:XSJ8Vk1SWuNr8S18z1NZSziL0CPIXLCCMDOEFtHBOFc=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20230530153820-e85fd2cbaebc/go.mod h1:66JfowdXAEgad5O9NnYcsNPLCPZJD++2L9X0PCMODrA=
+google.golang.org/grpc v1.55.0 h1:3Oj82/tFSCeUrRTg/5E/7d/W5A1tj6Ky1ABAuZuv5ag=
+google.golang.org/grpc v1.55.0/go.mod h1:iYEXKGkEBhg1PjZQvoYEVPTDkHo1/bjTnfwTeGONTY8=
 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.30.0 h1:kPPoIgf3TsEvrm0PFe15JQ+570QVxYzEvvHqChK+cng=
-google.golang.org/protobuf v1.30.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8=
+google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=

introspection/server.go

@@ -14,10 +14,16 @@ import (
  "github.com/quay/zlog"
  "go.opentelemetry.io/otel"
  "go.opentelemetry.io/otel/exporters/jaeger"
+ "go.opentelemetry.io/otel/exporters/otlp/otlptrace"
+ "go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc"
+ "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.7.0"
+ "google.golang.org/grpc/credentials"
+ "google.golang.org/grpc/encoding"
+ _ "google.golang.org/grpc/encoding/gzip"
 
  "github.com/quay/clair/v4/health"
 )
@@ -27,6 +33,7 @@ const (
  DefaultPromEndpoint = "/metrics"
  Stdout = "stdout"
  Jaeger = "jaeger"
+ OTLP = "otlp"
  HealthEndpoint = "/healthz"
  ReadyEndpoint = "/readyz"
  DefaultIntrospectionAddr = ":8089"
@@ -94,7 +101,7 @@ func New(ctx context.Context, conf config.Config, health func() bool) (*Server,
  sdktrace.TraceIDRatioBased(p),
  )
  default:
- sampler = sdktrace.NeverSample()
+ sampler = sdktrace.ParentBased(sdktrace.NeverSample())
  }
 
  // trace exporter
@@ -162,6 +169,75 @@ func New(ctx context.Context, conf config.Config, health func() bool) (*Server,
  if err != nil {
  return nil, fmt.Errorf("error configuring jaeger tracing: %w", err)
  }
+ case OTLP:
+ conf := i.conf.Trace.OTLP
+ var c otlptrace.Client
+ tlscfg, err := conf.ClientCert.Config()
+ if err != nil {
+ return nil, fmt.Errorf("error configuring otlp tracing: %w", err)
+ }
+ switch conf.Format {
+ case "", "http":
+ cfg := &conf.HTTP
+ opts := []otlptracehttp.Option{
+ otlptracehttp.WithTLSClientConfig(tlscfg),
+ }
+ if conf.Endpoint != nil {
+ opts = append(opts, otlptracehttp.WithEndpoint(*conf.Endpoint))
+ }
+ if i := conf.Insecure; i != nil && *i {
+ opts = append(opts, otlptracehttp.WithInsecure())
+ }
+ if conf.Headers != nil {
+ opts = append(opts, otlptracehttp.WithHeaders(conf.Headers))
+ }
+ if conf.Compression != nil {
+ switch z := *conf.Compression; z {
+ case "gzip":
+ opts = append(opts, otlptracehttp.WithCompression(otlptracehttp.GzipCompression))
+ default:
+ return nil, fmt.Errorf("error configuring otlp tracing: no such compression scheme: %q", z)
+ }
+ }
+
+ if p := cfg.URLPath; p != nil {
+ opts = append(opts, otlptracehttp.WithURLPath(*p))
+ }
+ c = otlptracehttp.NewClient(opts...)
+ case "grpc":
+ cfg := &conf.GRPC
+ opts := []otlptracegrpc.Option{
+ otlptracegrpc.WithTLSCredentials(credentials.NewTLS(tlscfg)),
+ }
+ if conf.Endpoint != nil {
+ opts = append(opts, otlptracegrpc.WithEndpoint(*conf.Endpoint))
+ }
+ if i := conf.Insecure; i != nil && *i {
+ opts = append(opts, otlptracegrpc.WithInsecure())
+ }
+ if conf.Headers != nil {
+ opts = append(opts, otlptracegrpc.WithHeaders(conf.Headers))
+ }
+ if conf.Compression != nil {
+ z := *conf.Compression
+ if encoding.GetCompressor(z) == nil {
+ return nil, fmt.Errorf("error configuring otlp tracing: no such compression scheme: %q", z)
+ }
+ opts = append(opts, otlptracegrpc.WithCompressor(z))
+ }
+
+ if srv := cfg.ServiceConfig; srv != nil {
+ opts = append(opts, otlptracegrpc.WithServiceConfig(*srv))
+ }
+ c = otlptracegrpc.NewClient(opts...)
+ default:
+ return nil, fmt.Errorf("error configuring otlp tracing: unknown format %q", conf.Format)
+ }
+
+ exporter, err = otlptrace.New(ctx, c)
+ if err != nil {
+ return nil, fmt.Errorf("error configuring otlp tracing: %w", err)
+ }
  default:
  zlog.Info(ctx).Msg("no distributed tracing enabled")
  }

local-dev/grafana/provisioning/datasources/datasource.yml

@@ -32,3 +32,9 @@ datasources:
  jsonData:
  path: http://clair-pyroscope:4040/
  editable: false
+- name: Jaeger
+ type: jaeger
+ access: proxy
+ orgId: 1
+ url: http://clair-jaeger:16686/jaeger/
+ editable: false

local-dev/traefik/config/clair.yaml

@@ -1,8 +1,5 @@
 ---
 http:
- entrypoint:
- clair:
- address: ':6060'
  routers:
  indexer:
  entryPoints: [clair]

local-dev/traefik/traefik.yaml

@@ -19,4 +19,8 @@ providers:
 metrics:
  prometheus:
  addServicesLabels: true
+tracing:
+ openTelemetry:
+ address: clair-jaeger:4318
+ insecure: true
 accessLog: {}