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
|
package httptransport
import (
"crypto/tls"
"net/http/httptrace"
"time"
"gitlab.com/gitlab-org/labkit/log"
)
func (mrt *meteredRoundTripper) newTracer(start time.Time) *httptrace.
ClientTrace {
trace := &httptrace.ClientTrace{
GetConn: func(host string) {
mrt.httpTraceObserve("httptrace.ClientTrace.GetConn", start)
log.WithFields(log.Fields{
"host": host,
}).Traceln("httptrace.ClientTrace.GetConn")
},
GotConn: func(connInfo httptrace.GotConnInfo) {
mrt.httpTraceObserve("httptrace.ClientTrace.GotConn", start)
log.WithFields(log.Fields{
"reused": connInfo.Reused,
"was_idle": connInfo.WasIdle,
"idle_time_ms": connInfo.IdleTime.Milliseconds(),
}).Traceln("httptrace.ClientTrace.GotConn")
},
GotFirstResponseByte: func() {
mrt.httpTraceObserve("httptrace.ClientTrace.GotFirstResponseByte", start)
},
DNSStart: func(d httptrace.DNSStartInfo) {
mrt.httpTraceObserve("httptrace.ClientTrace.DNSStart", start)
},
DNSDone: func(d httptrace.DNSDoneInfo) {
mrt.httpTraceObserve("httptrace.ClientTrace.DNSDone", start)
log.WithFields(log.Fields{}).WithError(d.Err).
Traceln("httptrace.ClientTrace.DNSDone")
},
ConnectStart: func(net, addr string) {
mrt.httpTraceObserve("httptrace.ClientTrace.ConnectStart", start)
log.WithFields(log.Fields{
"network": net,
"address": addr,
}).Traceln("httptrace.ClientTrace.ConnectStart")
},
ConnectDone: func(net string, addr string, err error) {
mrt.httpTraceObserve("httptrace.ClientTrace.ConnectDone", start)
l := log.WithFields(log.Fields{
"network": net,
"address": addr,
})
if err != nil {
l.WithError(err).Error("httptrace.ClientTrace.ConnectDone")
}
l.Traceln("httptrace.ClientTrace.ConnectDone")
},
TLSHandshakeStart: func() {
mrt.httpTraceObserve("httptrace.ClientTrace.TLSHandshakeStart", start)
},
TLSHandshakeDone: func(connState tls.ConnectionState, err error) {
mrt.httpTraceObserve("httptrace.ClientTrace.TLSHandshakeDone", start)
l := log.WithFields(log.Fields{
"version": connState.Version,
"connection_resumed": connState.DidResume,
})
if err != nil {
l.WithError(err).Error("httptrace.ClientTrace.TLSHandshakeDone")
}
l.Traceln("httptrace.ClientTrace.TLSHandshakeDone")
},
}
return trace
}
func (mrt *meteredRoundTripper) httpTraceObserve(label string, start time.Time) {
mrt.tracer.WithLabelValues(label).
Observe(time.Since(start).Seconds())
}
|
