http client timeout parameter (#26)

Author: PiotrLuczko

.gitignore

@@ -1,3 +1,6 @@
+# GoLand IDE
+.idea
+
 # Binaries for programs and plugins
 *.exe
 *.exe~

README.md

@@ -119,6 +119,7 @@ Advanced options can be configured as a parameter to the `Config` struct to the
 |MetadataOnly          |EPSAGON_METADATA              |Boolean|`true`       |Whether to send only the metadata (`True`) or also the payloads (`False`)          |
 |CollectorURL          |EPSAGON_COLLECTOR_URL         |String |-            |The address of the trace collector to send trace to                                |
 |Debug                 |EPSAGON_DEBUG                 |Boolean|`False`      |Enable debug prints for troubleshooting                                            |
+|SendTimeout           |EPSAGON_SEND_TIMEOUT_SEC      |String |`1s`         |The timeout duration to send the traces to the trace collector                     |
 
 
 

epsagon/tracer.go

@@ -39,6 +39,7 @@ func NewTracerConfig(applicationName, token string) *Config {
 		Token:           token,
 		MetadataOnly:    true,
 		Debug:           false,
+		SendTimeout:     "1s",
 	}
 }
 
@@ -49,6 +50,7 @@ type Config struct {
 	CollectorURL    string
 	MetadataOnly    bool
 	Debug           bool
+	SendTimeout     string
 }
 
 type epsagonTracer struct {
@@ -84,7 +86,13 @@ func (tracer *epsagonTracer) sendTraces() {
 		log.Printf("Epsagon: Encountered an error while marshaling the traces: %v\n", err)
 		return
 	}
-	client := &http.Client{Timeout: time.Duration(time.Second)}
+	sendTimeout, err := time.ParseDuration(tracer.Config.SendTimeout)
+	if err != nil {
+		log.Printf("Epsagon: Encountered an error while parsing send timeout: %v\n", err)
+		return
+	}
+
+	client := &http.Client{Timeout: sendTimeout}
 
 	handleSendTracesResponse(client.Post(tracer.Config.CollectorURL, "application/json", tracesReader))
 }
@@ -175,6 +183,13 @@ func fillConfigDefaults(config *Config) {
 			log.Printf("EPSAGON DEBUG: setting collector url to %s\n", config.CollectorURL)
 		}
 	}
+	sendTimeout := os.Getenv("EPSAGON_SEND_TIMEOUT_SEC")
+	if len(sendTimeout) != 0 {
+		config.SendTimeout = sendTimeout
+		if config.Debug {
+			log.Println("EPSAGON DEBUG: setting send timeout from environment variable")
+		}
+	}
 }
 
 // CreateTracer will initiallize a global epsagon tracer