|
|
@ -18,7 +18,6 @@ import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
"errors"
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"go.opentelemetry.io/otel/attribute"
|
|
|
|
|
|
|
|
"io"
|
|
|
|
"io"
|
|
|
|
"net/http"
|
|
|
|
"net/http"
|
|
|
|
"net/http/httptrace"
|
|
|
|
"net/http/httptrace"
|
|
|
@ -26,6 +25,8 @@ import (
|
|
|
|
"strings"
|
|
|
|
"strings"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
"go.opentelemetry.io/otel/attribute"
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/gogo/protobuf/proto"
|
|
|
|
"github.com/gogo/protobuf/proto"
|
|
|
|
"github.com/golang/snappy"
|
|
|
|
"github.com/golang/snappy"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
|
@ -289,7 +290,7 @@ func (c *Client) Store(ctx context.Context, req []byte, attempt int) (WriteRespo
|
|
|
|
span.AddEvent("GotConn", trace.WithAttributes(
|
|
|
|
span.AddEvent("GotConn", trace.WithAttributes(
|
|
|
|
attribute.Bool("reused", info.Reused),
|
|
|
|
attribute.Bool("reused", info.Reused),
|
|
|
|
attribute.Bool("wasIdle", info.WasIdle),
|
|
|
|
attribute.Bool("wasIdle", info.WasIdle),
|
|
|
|
//attribute.Duration("idleTime", info.IdleTime),
|
|
|
|
attribute.Float64("idleTimeMs", float64(info.IdleTime.Milliseconds())),
|
|
|
|
))
|
|
|
|
))
|
|
|
|
},
|
|
|
|
},
|
|
|
|
DNSStart: func(info httptrace.DNSStartInfo) {
|
|
|
|
DNSStart: func(info httptrace.DNSStartInfo) {
|
|
|
|