1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0
package semconv
import (
"context"
"net/http"
"testing"
"github.com/stretchr/testify/require"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
"go.opentelemetry.io/otel/metric/embedded"
"go.opentelemetry.io/otel/metric/noop"
)
func TestHTTPServerDoesNotPanic(t *testing.T) {
testCases := []struct {
name string
server HTTPServer
}{
{
name: "empty",
server: HTTPServer{},
},
{
name: "nil meter",
server: NewHTTPServer(nil),
},
{
name: "with Meter",
server: NewHTTPServer(noop.Meter{}),
},
}
for _, tt := range testCases {
t.Run(tt.name, func(t *testing.T) {
require.NotPanics(t, func() {
req, err := http.NewRequest("GET", "http://example.com", nil)
require.NoError(t, err)
_ = tt.server.RequestTraceAttrs("stuff", req)
_ = tt.server.ResponseTraceAttrs(ResponseTelemetry{StatusCode: 200})
tt.server.RecordMetrics(context.Background(), ServerMetricData{
ServerName: "stuff",
MetricAttributes: MetricAttributes{
Req: req,
},
})
})
})
}
}
func TestHTTPClientDoesNotPanic(t *testing.T) {
testCases := []struct {
name string
client HTTPClient
}{
{
name: "empty",
client: HTTPClient{},
},
{
name: "nil meter",
client: NewHTTPClient(nil),
},
{
name: "with Meter",
client: NewHTTPClient(noop.Meter{}),
},
}
for _, tt := range testCases {
t.Run(tt.name, func(t *testing.T) {
require.NotPanics(t, func() {
req, err := http.NewRequest("GET", "http://example.com", nil)
require.NoError(t, err)
_ = tt.client.RequestTraceAttrs(req)
_ = tt.client.ResponseTraceAttrs(&http.Response{StatusCode: 200})
opts := tt.client.MetricOptions(MetricAttributes{
Req: req,
StatusCode: 200,
})
tt.client.RecordResponseSize(context.Background(), 40, opts.AddOptions())
tt.client.RecordMetrics(context.Background(), MetricData{
RequestSize: 20,
ElapsedTime: 1,
}, opts)
})
})
}
}
type testInst struct {
embedded.Int64Counter
embedded.Float64Histogram
intValue int64
floatValue float64
attributes []attribute.KeyValue
}
func (t *testInst) Add(ctx context.Context, incr int64, options ...metric.AddOption) {
t.intValue = incr
cfg := metric.NewAddConfig(options)
attr := cfg.Attributes()
t.attributes = attr.ToSlice()
}
func (t *testInst) Record(ctx context.Context, value float64, options ...metric.RecordOption) {
t.floatValue = value
cfg := metric.NewRecordConfig(options)
attr := cfg.Attributes()
t.attributes = attr.ToSlice()
}
func NewTestHTTPServer() HTTPServer {
return HTTPServer{
requestBytesCounter: &testInst{},
responseBytesCounter: &testInst{},
serverLatencyMeasure: &testInst{},
}
}
func NewTestHTTPClient() HTTPClient {
return HTTPClient{
requestBytesCounter: &testInst{},
responseBytesCounter: &testInst{},
latencyMeasure: &testInst{},
}
}
|
