Httptrace

.changeset/sixty-lemons-move.md

@@ -0,0 +1,5 @@
+---
+'grafana-infinity-datasource': minor
+---
+
+Added HTTPTrace logging for debugging connection issues

docker/blocks/tempo/config.yaml

@@ -39,11 +39,6 @@ metrics_generator:
 storage:
   trace:
     backend: local # backend configuration to use
-    block:
-      bloom_filter_false_positive: .05 # bloom filter false positive rate.  lower values create larger filters but fewer false positives
-      v2_index_downsample_bytes: 1000 # number of bytes per index record
-      v2_encoding: zstd # block encoding/compression.  options: none, gzip, lz4-64k, lz4-256k, lz4-1M, lz4, snappy, zstd, s2
-      version: vParquet
     wal:
       path: /tmp/tempo/wal # where to store the the wal locally
       v2_encoding: snappy # wal encoding/compression.  options: none, gzip, lz4-64k, lz4-256k, lz4-1M, lz4, snappy, zstd, s2

pkg/infinity/httptrace.go

@@ -0,0 +1,52 @@
+package infinity
+
+import (
+	"crypto/tls"
+	"net/http"
+	"net/http/httptrace"
+
+	"github.com/grafana/grafana-plugin-sdk-go/backend"
+)
+
+func reqWithHTTPTraceContext(req *http.Request) *http.Request {
+	ctx := req.Context()
+	logger := backend.Logger.FromContext(ctx)
+	trace := &httptrace.ClientTrace{
+		GetConn: func(hostPort string) {
+			logger.Debug("HTTPTrace event", "event_name", "GetConn")
+		},
+		DNSStart: func(di httptrace.DNSStartInfo) {
+			logger.Debug("HTTPTrace event", "event_name", "DNSStart")
+		},
+		DNSDone: func(dnsInfo httptrace.DNSDoneInfo) {
+			logger.Debug("HTTPTrace event", "event_name", "DNSDone")
+		},
+		ConnectStart: func(network, addr string) {
+			logger.Debug("HTTPTrace event", "event_name", "ConnectStart")
+		},
+		ConnectDone: func(network, addr string, err error) {
+			if err != nil {
+				logger.Error("HTTPTrace event", "event_name", "ConnectDone", "error", err.Error())
+				return
+			}
+			logger.Debug("HTTPTrace event", "event_name", "ConnectDone", "address", addr)
+		},
+		TLSHandshakeStart: func() {
+			logger.Debug("HTTPTrace event", "event_name", "TLSHandshakeStart")
+		},
+		TLSHandshakeDone: func(cs tls.ConnectionState, err error) {
+			if err != nil {
+				logger.Error("HTTPTrace event", "event_name", "TLSHandshakeDone", "error", err.Error())
+				return
+			}
+			logger.Debug("HTTPTrace event", "event_name", "TLSHandshakeDone")
+		},
+		GotConn: func(connInfo httptrace.GotConnInfo) {
+			logger.Debug("HTTPTrace event", "event_name", "GotConn", "remote_address", connInfo.Conn.RemoteAddr().String())
+		},
+		GotFirstResponseByte: func() {
+			logger.Debug("HTTPTrace event", "event_name", "GotFirstResponseByte")
+		},
+	}
+	return req.WithContext(httptrace.WithClientTrace(ctx, trace))
+}

pkg/infinity/request.go

@@ -34,6 +34,7 @@ func GetRequest(ctx context.Context, settings models.InfinitySettings, body io.R
 	req = ApplyBearerToken(settings, req, includeSect)
 	req = ApplyApiKeyAuth(settings, req, includeSect)
 	req = ApplyForwardedOAuthIdentity(requestHeaders, settings, req, includeSect)
+	req = reqWithHTTPTraceContext(req)
 	return req, err
 }