feat: expose more regclient options

Signed-off-by: Łukasz Jakimczuk <ljakimczuk@gmail.com>

Author: ljakimczuk

pkg/extensions/config/sync/config.go

@@ -23,17 +23,20 @@ type Config struct {
 }
 
 type RegistryConfig struct {
-	URLs             []string
-	PollInterval     time.Duration
-	Content          []Content
-	TLSVerify        *bool
-	OnDemand         bool
-	CertDir          string
-	MaxRetries       *int
-	RetryDelay       *time.Duration
-	OnlySigned       *bool
-	CredentialHelper string
-	PreserveDigest   bool // sync without converting
+	URLs               []string
+	PollInterval       time.Duration
+	Content            []Content
+	TLSVerify          *bool
+	OnDemand           bool
+	CertDir            string
+	MaxRetries         *int
+	RetryDelay         *time.Duration
+	OnlySigned         *bool
+	CredentialHelper   string
+	PreserveDigest     bool // sync without converting
+	ClientLogs         bool // creates regclient log/slog logger
+	ClientLogsLevel    string // defines regclient log/slog logger level
+	ConcurrentRequests int64 // reqclient active requests
 }
 
 type Content struct {

pkg/extensions/sync/service.go

@@ -7,7 +7,9 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log/slog"
 	"net/url"
+	"os"
 	"strconv"
 	"strings"
 	"sync"
@@ -146,7 +148,7 @@ func (service *BaseService) init() error {
 
 	client, hosts, err := newClient(service.config, service.credentials)
 	if err != nil {
-		service.log.Err(err).Msg("failed to parse sync config urls")
+		service.log.Err(err).Msg("failed to create registry client")
 
 		return err
 	}
@@ -804,6 +806,7 @@ func newClient(opts syncconf.RegistryConfig, credentials syncconf.CredentialsFil
 		hostConfig = *host
 	}
 
+	hostConfig.ReqConcurrent = opts.ConcurrentRequests
 	hostConfig.Name = mainHost
 	hostConfig.Hostname = mainHost
 	hostConfig.Mirrors = mirrorsHosts
@@ -870,12 +873,31 @@ func newClient(opts syncconf.RegistryConfig, credentials syncconf.CredentialsFil
 		regOpts = append(regOpts, reg.WithDelay(*opts.RetryDelay, *opts.RetryDelay))
 	}
 
-	client := regclient.New(
+	clientOpts := []regclient.Opt{
 		regclient.WithDockerCerts(),
 		regclient.WithDockerCreds(),
 		regclient.WithRegOpts(regOpts...),
 		regclient.WithConfigHost(hostConfigOpts...),
-	)
+	}
+
+	if opts.ClientLogs {
+		ho := &slog.HandlerOptions{AddSource: true}
+
+		if opts.ClientLogsLevel != "" {
+			lvl := slog.Level(0)
+
+			err = lvl.UnmarshalText([]byte(opts.ClientLogsLevel))
+			if err != nil {
+				return nil, nil, err
+			}
+
+			ho.Level = lvl
+		}
+
+		clientOpts = append(clientOpts, regclient.WithSlog(slog.New(slog.NewJSONHandler(os.Stdout, ho))))
+	}
+
+	client := regclient.New(clientOpts...)
 
 	return client, hostConfigOpts, nil
 }