From 34411fa178d4c91d97432d933b191ceb6ef83988 Mon Sep 17 00:00:00 2001
From: Yorjander Hernandez Vergara <yorjaKbayero@gmail.com>
Date: Tue, 23 Jan 2024 14:53:28 +0200
Subject: [PATCH] Fix error cannot assign requested address

---
 log-auth-proxy/logservice/output_service.go | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/log-auth-proxy/logservice/output_service.go b/log-auth-proxy/logservice/output_service.go
index 05cb2e605..2952c6ef9 100644
--- a/log-auth-proxy/logservice/output_service.go
+++ b/log-auth-proxy/logservice/output_service.go
@@ -15,16 +15,22 @@ import (
 	"github.com/utmstack/UTMStack/log-auth-proxy/panelservice"
 )
 
+var transport = &http.Transport{
+	MaxIdleConns: 100,
+}
+
 type LogOutputService struct {
 	Connections map[model.LogType]string
 	Mutex       sync.Mutex
 	Ticker      *time.Ticker
+	Client      *http.Client
 }
 
 func NewLogOutputService() *LogOutputService {
 	connections, _ := getServiceMap()
 	return &LogOutputService{
 		Connections: connections,
+		Client:      &http.Client{Transport: transport},
 	}
 
 }
@@ -76,10 +82,13 @@ func (out *LogOutputService) getConnectionPort(logType model.LogType) (string, e
 }
 
 func (out *LogOutputService) sendLogsToLogstash(port string, logs string) {
-	client := &http.Client{}
 	url := fmt.Sprintf(config.LogstashPipelinesEndpoint, config.LogstashHost(), port)
 	req, err := http.NewRequest("POST", url, bytes.NewBufferString(logs))
-	resp, err := client.Do(req)
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	resp, err := out.Client.Do(req)
 	if err != nil {
 		fmt.Println(err)
 		return