add timeout

This commit is contained in:
Sergey Zhemoytel 2024-12-09 02:17:16 +03:00
parent 25fd6c7277
commit e6f1c3e66f

View file

@ -44,7 +44,7 @@ type AbfJson struct {
client *http.Client client *http.Client
} }
func NewAbfJson(abfURL, fileStoreURL, login, password string, logger *log.Logger) (*AbfJson, error) { func NewAbfJson(abfURL, fileStoreURL, login, password string, logger *log.Logger, timeout time.Duration) (*AbfJson, error) {
if !strings.HasPrefix(fileStoreURL, "http://") && !strings.HasPrefix(fileStoreURL, "https://") { if !strings.HasPrefix(fileStoreURL, "http://") && !strings.HasPrefix(fileStoreURL, "https://") {
return nil, errors.New("file-store URL has to start with \"http(s)://\"") return nil, errors.New("file-store URL has to start with \"http(s)://\"")
} }
@ -56,7 +56,7 @@ func NewAbfJson(abfURL, fileStoreURL, login, password string, logger *log.Logger
client := &http.Client{ client := &http.Client{
Transport: transport, Transport: transport,
Timeout: 30 * time.Second, Timeout: timeout,
} }
lpw := fmt.Sprintf("%s:%s", login, password) lpw := fmt.Sprintf("%s:%s", login, password)