Exemple
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0: WithTLSCredentials
Échantillon vérifié pour golang go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0: WithTLSCredentials. Le contrat s'est exécuté sur go…
sha256:ae71d4347ca4d4eeff401d5e946c76db119e677a2753524fffb202638c764bdf
Ce réseau offre une seule chose : un échantillon qui compile. Il l'a exécuté dans un bac à sable et conservé le reçu signé. Il ne note rien et ne garantit rien : si le même code compile chez vous, il ne l'a pas mesuré.
Combien de clés de signature distinctes ont déposé un reçu de contrat réussi. Une seule, c'est l'auteur ; plus d'une signifie que quelqu'un d'autre l'a compilé aussi. Une clé est auto-générée sans identité enregistrée derrière, donc on compte des clés, pas des personnes.
MIT-0
Preuves d'exécution
L'environnement déclaré et les exécutions signées sont séparés, pour que vous voyiez exactement ce que cet échantillon a exécuté et où.
- Base de preuve
- Contrat signé réussi
- Reçus de vérification
- 3
- Clés de signature qui l’ont compilé
- 1
Environnement déclaré
go 1.26 linux 24 · ubuntu · glibc 2.39 x64 go 1.26 go go 1
Environnements des exécutions de vérification
| Environnement | Contrat | Étapes | Exécution |
|---|---|---|---|
| go 1.26 · linux debian/x64 · docker ed25519:c1973797be207ac4 | FAIL | compile:SKIPPED · contract:FAIL · load:SKIPPED · resolve:PASS CONTAINER_RUN · golang@1golang:1.26@sha256:e30143be198a… |
2026-09-01 |
| go 1.26 · linux debian/x64 · docker ed25519:c1973797be207ac4 | FAIL | compile:SKIPPED · contract:FAIL · load:SKIPPED · resolve:PASS CONTAINER_RUN · golang@1golang:1.26@sha256:e30143be198a… |
2026-09-01 |
| go 1.26 · linux debian/x64 · docker ed25519:c1973797be207ac4 | PASS | compile:SKIPPED · contract:PASS · load:PASS · resolve:PASS CONTAINER_RUN · golang@1golang:1.26@sha256:e30143be198a… |
2026-09-01 |
Cas
HOW- Objectif
- verify WithTLSCredentials in pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0
- Symboles
-
- WithTLSCredentials
- Environnement
- go 1.26.6
- Créé
- 2026-09-01T09:56:30Z
Contrat
- otlptracegrpc.WithTLSCredentials returns a non-nil Option
- otlptracegrpc.NewClient accepts WithTLSCredentials Option and returns non-nil Client
- otlptracegrpc.New creates an otlptrace Exporter with WithTLSCredentials Option
- Exported spans deliver trace ID, span ID, span name, and attributes across TLS gRPC
- Exporter Shutdown flushes pending spans and releases connection resources cleanly
Fichiers
- PROMPT.md
- csx.json
- go.mod
- go.sum
- sample.go
- spec.json
- test/contract_test.go
Code source
Clean-room public code sample — generation instructions
Write a brand-new, minimal, self-contained code sample in this clean-room directory.
Do not copy, paraphrase, or reference any existing project source. Work only from this spec.
A csx.json manifest scaffold already exists. Do not recreate it from memory. Preserve its case.goal, packages and symbols; fill its empty case.contract with exact assertions and correct its environment, commands and verifierAdapter for the files you generate.
Goal: verify WithTLSCredentials in pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0
Kind: HOW
Use EXACTLY these public packages and versions:
- pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0
Demonstrate these symbols/APIs:
- WithTLSCredentials
Constraints:
- executionContext: node
Required runtime conditions:
- ecosystem: npm
- language: javascript
- moduleSystem: cjs
- packageManager: npm@10.9.8
- runtime: node@22.23.2
Rules:
- One focused purpose; the smallest project that proves the goal.
- Include a contract test (test/contract.*) that runs OFFLINE and exits 0 exactly when the goal behavior works.
- Pin every dependency with a lockfile so resolution is reproducible.
- No secrets, credentials, or tokens. No real URLs (only example.com or localhost). No absolute paths.
- No personal names, emails, company names, or project identifiers of any kind.
- No binaries and no generated output (node_modules, dist, target, venv, .git, .env).
- Keep it under 200 files and 256KB packed.
{"case":{"caseId":"case:sha256:123288701a03dfa671b5667e567b1121959b793b3ea584f25e612f21856f1949","contract":["otlptracegrpc.WithTLSCredentials returns a non-nil Option","otlptracegrpc.NewClient accepts WithTLSCredentials Option and returns non-nil Client","otlptracegrpc.New creates an otlptrace Exporter with WithTLSCredentials Option","Exported spans deliver trace ID, span ID, span name, and attributes across TLS gRPC","Exporter Shutdown flushes pending spans and releases connection resources cleanly"],"goal":"verify WithTLSCredentials in pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0","kind":"HOW","packages":["pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0"],"schemaVersion":1,"symbols":["WithTLSCredentials"]},"contractCommand":["go","test","./..."],"environment":{"arch":"x64","distro":"ubuntu","ecosystem":"golang","language":"go","libc":"glibc","libcVersion":"2.39","moduleSystem":"go.mod","os":"linux","osVersionBucket":"24","packageManager":"go","packageManagerVersion":"1.26.6","runtime":"go","runtimeVersion":"1.26.6","schemaVersion":1},"license":"MIT-0","packages":["pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0"],"schemaVersion":1,"subject":"pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0","symbols":["WithTLSCredentials"],"verifierAdapter":"golang@1"}
module example.com/sample
go 1.26.6
require (
go.opentelemetry.io/otel v1.43.0
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0
go.opentelemetry.io/otel/sdk v1.43.0
go.opentelemetry.io/otel/trace v1.43.0
go.opentelemetry.io/proto/otlp v1.10.0
google.golang.org/grpc v1.80.0
)
require (
github.com/cenkalti/backoff/v5 v5.0.3 // indirect
github.com/cespare/xxhash/v2 v2.3.0 // indirect
github.com/go-logr/logr v1.4.3 // indirect
github.com/go-logr/stdr v1.2.2 // indirect
github.com/google/uuid v1.6.0 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 // indirect
go.opentelemetry.io/auto/sdk v1.2.1 // indirect
go.opentelemetry.io/otel/metric v1.43.0 // indirect
golang.org/x/net v0.52.0 // indirect
golang.org/x/sys v0.42.0 // indirect
golang.org/x/text v0.35.0 // indirect
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 // indirect
google.golang.org/protobuf v1.36.11 // indirect
)
github.com/cenkalti/backoff/v5 v5.0.3 h1:ZN+IMa753KfX5hd8vVaMixjnqRZ3y8CuJKRKj1xcsSM=
github.com/cenkalti/backoff/v5 v5.0.3/go.mod h1:rkhZdG3JZukswDf7f0cwqPNk4K0sa+F97BxZthm/crw=
github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
github.com/go-logr/logr v1.4.3/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.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 h1:HWRh5R2+9EifMyIHV7ZV+MIZqgz+PMpZ14Jynv3O2Zs=
github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0/go.mod h1:JfhWUomR1baixubs02l85lZYYOm7LV6om4ceouMv45c=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
go.opentelemetry.io/otel v1.43.0 h1:mYIM03dnh5zfN7HautFE4ieIig9amkNANT+xcVxAj9I=
go.opentelemetry.io/otel v1.43.0/go.mod h1:JuG+u74mvjvcm8vj8pI5XiHy1zDeoCS2LB1spIq7Ay0=
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0 h1:88Y4s2C8oTui1LGM6bTWkw0ICGcOLCAI5l6zsD1j20k=
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0/go.mod h1:Vl1/iaggsuRlrHf/hfPJPvVag77kKyvrLeD10kpMl+A=
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0 h1:RAE+JPfvEmvy+0LzyUA25/SGawPwIUbZ6u0Wug54sLc=
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0/go.mod h1:AGmbycVGEsRx9mXMZ75CsOyhSP6MFIcj/6dnG+vhVjk=
go.opentelemetry.io/otel/metric v1.43.0 h1:d7638QeInOnuwOONPp4JAOGfbCEpYb+K6DVWvdxGzgM=
go.opentelemetry.io/otel/metric v1.43.0/go.mod h1:RDnPtIxvqlgO8GRW18W6Z/4P462ldprJtfxHxyKd2PY=
go.opentelemetry.io/otel/sdk v1.43.0 h1:pi5mE86i5rTeLXqoF/hhiBtUNcrAGHLKQdhg4h4V9Dg=
go.opentelemetry.io/otel/sdk v1.43.0/go.mod h1:P+IkVU3iWukmiit/Yf9AWvpyRDlUeBaRg6Y+C58QHzg=
go.opentelemetry.io/otel/sdk/metric v1.43.0 h1:S88dyqXjJkuBNLeMcVPRFXpRw2fuwdvfCGLEo89fDkw=
go.opentelemetry.io/otel/sdk/metric v1.43.0/go.mod h1:C/RJtwSEJ5hzTiUz5pXF1kILHStzb9zFlIEe85bhj6A=
go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09nk+3A=
go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
go.opentelemetry.io/proto/otlp v1.10.0 h1:IQRWgT5srOCYfiWnpqUYz9CVmbO8bFmKcwYxpuCSL2g=
go.opentelemetry.io/proto/otlp v1.10.0/go.mod h1:/CV4QoCR/S9yaPj8utp3lvQPoqMtxXdzn7ozvvozVqk=
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.52.0 h1:He/TN1l0e4mmR3QqHMT2Xab3Aj3L9qjbhRm78/6jrW0=
golang.org/x/net v0.52.0/go.mod h1:R1MAz7uMZxVMualyPXb+VaqGSa3LIaUqk0eEt3w36Sw=
golang.org/x/sys v0.42.0 h1:omrd2nAlyT5ESRdCLYdm3+fMfNFE/+Rf4bDIQImRJeo=
golang.org/x/sys v0.42.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
golang.org/x/text v0.35.0 h1:JOVx6vVDFokkpaq1AEptVzLTpDe9KGpj5tR4/X+ybL8=
golang.org/x/text v0.35.0/go.mod h1:khi/HExzZJ2pGnjenulevKNX1W67CUy0AsXcNubPGCA=
gonum.org/v1/gonum v0.17.0 h1:VbpOemQlsSMrYmn7T2OUvQ4dqxQXU+ouZFQsZOx50z4=
gonum.org/v1/gonum v0.17.0/go.mod h1:El3tOrEuMpv2UdMrbNlKEh9vd86bmQ6vqIcDwxEOc1E=
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 h1:VPWxll4HlMw1Vs/qXtN7BvhZqsS9cdAittCNvVENElA=
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:7QBABkRtR8z+TEnmXTqIqwJLlzrZKVfAUm7tY3yGv0M=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 h1:m8qni9SQFH0tJc1X0vmnpw/0t+AImlSvp30sEupozUg=
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
google.golang.org/grpc v1.80.0 h1:Xr6m2WmWZLETvUNvIUmeD5OAagMw3FiKmMlTdViWsHM=
google.golang.org/grpc v1.80.0/go.mod h1:ho/dLnxwi3EDJA4Zghp7k2Ec1+c2jqup0bFkw07bwF4=
google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
package sample
import (
"context"
"crypto/tls"
"fmt"
"go.opentelemetry.io/otel/exporters/otlp/otlptrace"
"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
)
// ExporterConfig holds configuration options for OTLP trace gRPC exporter with TLS.
type ExporterConfig struct {
Endpoint string
Credentials credentials.TransportCredentials
DialOptions []grpc.DialOption
GRPCConn *grpc.ClientConn
}
// NewExporterWithTLSCredentials creates an OTLP trace exporter configured with TLS credentials.
func NewExporterWithTLSCredentials(ctx context.Context, cfg ExporterConfig) (*otlptrace.Exporter, error) {
var opts []otlptracegrpc.Option
if cfg.Credentials != nil {
opts = append(opts, otlptracegrpc.WithTLSCredentials(cfg.Credentials))
}
if cfg.Endpoint != "" {
opts = append(opts, otlptracegrpc.WithEndpoint(cfg.Endpoint))
}
if cfg.GRPCConn != nil {
opts = append(opts, otlptracegrpc.WithGRPCConn(cfg.GRPCConn))
}
for _, do := range cfg.DialOptions {
opts = append(opts, otlptracegrpc.WithDialOption(do))
}
exp, err := otlptracegrpc.New(ctx, opts...)
if err != nil {
return nil, fmt.Errorf("failed to create otlptrace exporter: %w", err)
}
return exp, nil
}
// NewClientWithTLSConfig creates an OTLP trace gRPC client configured with TLS credentials from a tls.Config.
func NewClientWithTLSConfig(tlsConfig *tls.Config, endpoint string) otlptrace.Client {
creds := credentials.NewTLS(tlsConfig)
opts := []otlptracegrpc.Option{
otlptracegrpc.WithTLSCredentials(creds),
}
if endpoint != "" {
opts = append(opts, otlptracegrpc.WithEndpoint(endpoint))
}
return otlptracegrpc.NewClient(opts...)
}
{
"schemaVersion": 1,
"goal": "verify WithTLSCredentials in pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0",
"kind": "HOW",
"packages": [
"pkg:golang/go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc@v1.43.0"
],
"symbols": [
"WithTLSCredentials"
],
"runtimeConditions": {
"ecosystem": "golang",
"language": "go",
"packageManager": "go@1.26.6",
"runtime": "go@1.26.6"
}
}
package test
import (
"context"
"crypto/ecdsa"
"crypto/elliptic"
"crypto/rand"
"crypto/tls"
"crypto/x509"
"crypto/x509/pkix"
"math/big"
"net"
"sync"
"testing"
"time"
sample "example.com/sample"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc"
sdktrace "go.opentelemetry.io/otel/sdk/trace"
"go.opentelemetry.io/otel/trace"
coltracepb "go.opentelemetry.io/proto/otlp/collector/trace/v1"
tracepb "go.opentelemetry.io/proto/otlp/trace/v1"
"google.golang.org/grpc"
"google.golang.org/grpc/credentials"
"google.golang.org/grpc/test/bufconn"
)
type mockTraceServer struct {
coltracepb.UnimplementedTraceServiceServer
mu sync.Mutex
requests []*coltracepb.ExportTraceServiceRequest
}
func (s *mockTraceServer) Export(ctx context.Context, req *coltracepb.ExportTraceServiceRequest) (*coltracepb.ExportTraceServiceResponse, error) {
s.mu.Lock()
defer s.mu.Unlock()
s.requests = append(s.requests, req)
return &coltracepb.ExportTraceServiceResponse{}, nil
}
func (s *mockTraceServer) getRequests() []*coltracepb.ExportTraceServiceRequest {
s.mu.Lock()
defer s.mu.Unlock()
copied := make([]*coltracepb.ExportTraceServiceRequest, len(s.requests))
copy(copied, s.requests)
return copied
}
func generateSelfSignedCert(t *testing.T) (tls.Certificate, *x509.CertPool) {
t.Helper()
priv, err := ecdsa.GenerateKey(elliptic.P256(), rand.Reader)
if err != nil {
t.Fatalf("failed to generate private key: %v", err)
}
template := x509.Certificate{
SerialNumber: big.NewInt(1),
Subject: pkix.Name{
Organization: []string{"Example Org"},
CommonName: "localhost",
},
NotBefore: time.Now().Add(-1 * time.Hour),
NotAfter: time.Now().Add(24 * time.Hour),
KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature,
ExtKeyUsage: []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth, x509.ExtKeyUsageClientAuth},
BasicConstraintsValid: true,
DNSNames: []string{"localhost", "example.com"},
IPAddresses: []net.IP{net.ParseIP("127.0.0.1")},
}
derBytes, err := x509.CreateCertificate(rand.Reader, &template, &template, &priv.PublicKey, priv)
if err != nil {
t.Fatalf("failed to create certificate: %v", err)
}
cert := tls.Certificate{
Certificate: [][]byte{derBytes},
PrivateKey: priv,
}
certPool := x509.NewCertPool()
parsedCert, err := x509.ParseCertificate(derBytes)
if err != nil {
t.Fatalf("failed to parse certificate: %v", err)
}
certPool.AddCert(parsedCert)
return cert, certPool
}
func TestWithTLSCredentialsContract(t *testing.T) {
ctx := context.Background()
serverCert, certPool := generateSelfSignedCert(t)
clientTLSConfig := &tls.Config{
RootCAs: certPool,
ServerName: "localhost",
}
clientCreds := credentials.NewTLS(clientTLSConfig)
// 1. otlptracegrpc.WithTLSCredentials returns a non-nil Option
opt := otlptracegrpc.WithTLSCredentials(clientCreds)
if opt == nil {
t.Fatal("expected otlptracegrpc.WithTLSCredentials to return a non-nil Option")
}
// 2. otlptracegrpc.NewClient accepts WithTLSCredentials Option and returns non-nil Client
client := sample.NewClientWithTLSConfig(clientTLSConfig, "localhost:4317")
if client == nil {
t.Fatal("expected non-nil Client from NewClientWithTLSConfig")
}
// 3. otlptracegrpc.New creates an otlptrace Exporter with WithTLSCredentials Option
expDirect, err := sample.NewExporterWithTLSCredentials(ctx, sample.ExporterConfig{
Endpoint: "localhost:4317",
Credentials: clientCreds,
})
if err != nil {
t.Fatalf("failed to create exporter with TLS credentials: %v", err)
}
if expDirect == nil {
t.Fatal("expected non-nil exporter")
}
_ = expDirect.Shutdown(ctx)
// Set up in-memory TLS gRPC server
const bufSize = 1024 * 1024
lis := bufconn.Listen(bufSize)
serverCreds := credentials.NewServerTLSFromCert(&serverCert)
srv := grpc.NewServer(grpc.Creds(serverCreds))
mockServer := &mockTraceServer{}
coltracepb.RegisterTraceServiceServer(srv, mockServer)
go func() {
_ = srv.Serve(lis)
}()
defer srv.Stop()
// Connect gRPC client through bufconn using TLS credentials
bufDialer := func(context.Context, string) (net.Conn, error) {
return lis.Dial()
}
exp, err := sample.NewExporterWithTLSCredentials(ctx, sample.ExporterConfig{
Endpoint: "passthrough://bufnet",
Credentials: clientCreds,
DialOptions: []grpc.DialOption{
grpc.WithContextDialer(bufDialer),
},
})
if err != nil {
t.Fatalf("failed to create exporter with bufconn dialer and TLS credentials: %v", err)
}
tp := sdktrace.NewTracerProvider(sdktrace.WithSyncer(exp))
tracer := tp.Tracer("contract-test-tracer")
spanName := "tls-span"
_, span := tracer.Start(ctx, spanName,
trace.WithAttributes(
attribute.String("security.protocol", "tls"),
attribute.Int("test.iteration", 1),
),
)
spanCtx := span.SpanContext()
wantTraceID := spanCtx.TraceID()
wantSpanID := spanCtx.SpanID()
span.End()
if err := tp.ForceFlush(ctx); err != nil {
t.Fatalf("ForceFlush failed: %v", err)
}
// 4. Exported spans deliver trace ID, span ID, span name, and attributes across TLS gRPC
reqs := mockServer.getRequests()
if len(reqs) == 0 {
t.Fatal("expected at least one gRPC export request over TLS, got none")
}
var foundSpan *tracepb.Span
for _, req := range reqs {
for _, rs := range req.GetResourceSpans() {
for _, ss := range rs.GetScopeSpans() {
for _, s := range ss.GetSpans() {
if s.GetName() == spanName {
foundSpan = s
break
}
}
}
}
}
if foundSpan == nil {
t.Fatalf("expected span with name %q not found in received gRPC payloads", spanName)
}
if [16]byte(foundSpan.GetTraceId()) != wantTraceID {
t.Fatalf("trace ID mismatch: got %x, want %x", foundSpan.GetTraceId(), wantTraceID)
}
if [8]byte(foundSpan.GetSpanId()) != wantSpanID {
t.Fatalf("span ID mismatch: got %x, want %x", foundSpan.GetSpanId(), wantSpanID)
}
attrMap := make(map[string]any)
for _, kv := range foundSpan.GetAttributes() {
if kv.GetValue().GetStringValue() != "" {
attrMap[kv.GetKey()] = kv.GetValue().GetStringValue()
} else if kv.GetValue().GetIntValue() != 0 {
attrMap[kv.GetKey()] = kv.GetValue().GetIntValue()
}
}
if gotVal := attrMap["security.protocol"]; gotVal != "tls" {
t.Fatalf("span attribute security.protocol mismatch: got %v, want tls", gotVal)
}
if gotVal := attrMap["test.iteration"]; gotVal != int64(1) {
t.Fatalf("span attribute test.iteration mismatch: got %v, want 1", gotVal)
}
// 5. Exporter Shutdown flushes pending spans and releases connection resources cleanly
if err := tp.Shutdown(ctx); err != nil {
t.Fatalf("TracerProvider shutdown failed: %v", err)
}
if err := exp.Shutdown(ctx); err != nil {
t.Fatalf("Exporter shutdown failed: %v", err)
}
}
Seeder d'origine
anonyme