diff --git a/pkg/aggregation/server.go b/pkg/aggregation/server.go index b0b3a744..a75df58c 100644 --- a/pkg/aggregation/server.go +++ b/pkg/aggregation/server.go @@ -4,6 +4,7 @@ import ( "context" "crypto/tls" "crypto/x509" + "fmt" "net" "net/http" "strings" @@ -72,6 +73,7 @@ func serve(ctx context.Context, dialer websocket.Dialer, url string, headers htt return err } defer conn.Close() + ctx = context.WithValue(ctx, remotedialer.ContextKeyCaller, fmt.Sprintf("steve server: url:%s", url)) go func() { <-ctx.Done()