added a module to refactor the method

Author: afzal442

pkg/services/alertmanager.go

@@ -211,18 +211,10 @@ func (s alertmanagerService) Send(notification Notification, dest Destination) e
 func (s alertmanagerService) sendOneTarget(ctx context.Context, target string, rawBody []byte) (err error) {
 	rawURL := fmt.Sprintf("%v://%v%v", s.opts.Scheme, target, s.opts.APIPath)
 
-	var idleConnTimeout time.Duration
-	if s.opts.IdleConnTimeout != "" {
-		idleConnTimeout, err = time.ParseDuration(s.opts.IdleConnTimeout)
-		if err != nil {
-			return fmt.Errorf("failed to parse idle connection timeout: %w", err)
-		}
-	}
-	transport := httputil.NewTransport(rawURL, s.opts.MaxIdleConns, s.opts.MaxIdleConnsPerHost, s.opts.MaxConnsPerHost, idleConnTimeout, s.opts.InsecureSkipVerify)
-	client := &http.Client{
-		Transport: httputil.NewLoggingRoundTripper(transport, s.entry),
+	client, err := httputil.NewServiceHTTPClient(s.opts.MaxIdleConns, s.opts.MaxIdleConnsPerHost, s.opts.MaxConnsPerHost, s.opts.IdleConnTimeout, s.opts.InsecureSkipVerify, rawURL, "alertmeanger")
+	if err != nil {
+		return err
 	}
-
 	req, err := http.NewRequestWithContext(ctx, http.MethodPost, rawURL, bytes.NewReader(rawBody))
 	if err != nil {
 		return err

pkg/util/http/transport.go

@@ -3,9 +3,12 @@ package http
 import (
 	"crypto/tls"
 	"crypto/x509"
+	"fmt"
 	"net/http"
 	"net/url"
 	"time"
+
+	log "github.com/sirupsen/logrus"
 )
 
 var certResolver func(serverName string) ([]string, error)
@@ -43,6 +46,20 @@ func NewTransport(rawURL string, maxIdleConns int, maxIdleConnsPerHost int, maxC
 	return transport
 }
 
+func NewServiceHTTPClient(maxIdleConns, maxIdleConnsPerHost, maxConnsPerHost int, idleConnTimeout string, insecureSkipVerify bool, apiURL string, serviceName string) (client *http.Client, err error) {
+	var timeout time.Duration
+	if idleConnTimeout != "" {
+		timeout, err = time.ParseDuration(idleConnTimeout)
+		if err != nil {
+			return nil, fmt.Errorf("failed to parse idle connection timeout: %w", err)
+		}
+	}
+	transport := NewTransport(apiURL, maxIdleConns, maxIdleConnsPerHost, maxConnsPerHost, timeout, insecureSkipVerify)
+	return &http.Client{
+		Transport: NewLoggingRoundTripper(transport, log.WithField("service", serviceName)),
+	}, nil
+}
+
 func getCertPoolFromPEMData(pemData []string) *x509.CertPool {
 	certPool := x509.NewCertPool()
 	for _, pem := range pemData {