tracer: move es transport to net/http + format

filecoin-project · May 22, 2023 · 42d2f4d · 42d2f4d
1 parent bb92984
commit 42d2f4d
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 76 deletions.
diff --git a/node/modules/lp2p/pubsub.go b/node/modules/lp2p/pubsub.go
@@ -645,7 +645,7 @@ func (trw *tracerWrapper) Trace(evt *pubsub_pb.TraceEvent) {
 			}
 		}
 		// check if there was any of the Iwant msgs
-		validIwant := len(iwant) > 0 
+		validIwant := len(iwant) > 0
 
 		// trace the msgs if any of the flags was triggered
 		if validIhave || validIwant || validTopic {

diff --git a/node/modules/tracer/elasticsearch_transport.go b/node/modules/tracer/elasticsearch_transport.go
@@ -5,6 +5,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"net/http"
 	"net/url"
 	"time"
 
@@ -34,7 +35,7 @@ func NewElasticSearchTransport(connectionString string, elasticsearchIndex strin
 		},
 		Username:  username,
 		Password:  password,
-		Transport: &FastHttpTransport{},
+		Transport: &http.Transport{},
 	}
 
 	es, err := elasticsearch.NewClient(cfg)

diff --git a/node/modules/tracer/fasthttp_transport.go b/node/modules/tracer/fasthttp_transport.go