updated retry dial signature

elastic · Aug 28, 2024 · 0cbfdb2 · 0cbfdb2
1 parent 2e0c6b1
commit 0cbfdb2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/x-pack/filebeat/input/streaming/websocket.go b/x-pack/filebeat/input/streaming/websocket.go
@@ -224,7 +224,7 @@ func connectWebSocket(ctx context.Context, cfg config, url string, log *logp.Log
 	if cfg.Retry != nil {
 		retryConfig := cfg.Retry
 		for attempt := 1; attempt <= retryConfig.MaxAttempts; attempt++ {
-			conn, response, err = websocket.DefaultDialer.Dial(url, nil)
+			conn, response, err = websocket.DefaultDialer.DialContext(ctx, url, headers)
 			if err == nil {
 				return conn, response, nil
 			}