[Feature] [Platform] Improve Registry Performance (#1934)

Author: ajanikow

CHANGELOG.md

@@ -10,6 +10,7 @@
 - (Bugfix) (Platform) Prevent NPE in case of missing Helm Release 
 - (Feature) Unify Errors
 - (Documentation) Update Service Values Doc Type
+- (Feature) (Platform) Improve Registry Performance
 
 ## [1.2.50](https://github.com/arangodb/kube-arangodb/tree/1.2.50) (2025-07-04)
 - (Feature) (Platform) MetaV1 Integration Service

docs/api/ArangoBackupPolicy.V1.md

@@ -42,7 +42,7 @@ Parsed by https://godoc.org/github.com/robfig/cron
 
 Type: `meta.LabelSelector` <sup>[\[ref\]](https://github.com/arangodb/kube-arangodb/blob/1.2.50/pkg/apis/backup/v1/backup_policy_spec.go#L39)</sup>
 
-DeploymentSelector Selector definition for selecting matching ArangoBackup Custom Resources.
+DeploymentSelector Selector definition for selecting matching ArangoDeployment Custom Resources.
 
 Links:
 * [Kubernetes Documentation](https://godoc.org/k8s.io/apimachinery/pkg/apis/meta/v1#LabelSelector)

pkg/apis/backup/v1/backup_policy_spec.go

@@ -1,7 +1,7 @@
 //
 // DISCLAIMER
 //
-// Copyright 2016-2023 ArangoDB GmbH, Cologne, Germany
+// Copyright 2016-2025 ArangoDB GmbH, Cologne, Germany
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -33,7 +33,7 @@ type ArangoBackupPolicySpec struct {
 	// AllowConcurrent if false, ArangoBackup will not be created when previous Backups are not finished
 	// +doc/default: true
 	AllowConcurrent *bool `json:"allowConcurrent,omitempty"`
-	// DeploymentSelector Selector definition for selecting matching ArangoBackup Custom Resources.
+	// DeploymentSelector Selector definition for selecting matching ArangoDeployment Custom Resources.
 	// +doc/type: meta.LabelSelector
 	// +doc/link: Kubernetes Documentation|https://godoc.org/k8s.io/apimachinery/pkg/apis/meta/v1#LabelSelector
 	DeploymentSelector *meta.LabelSelector `json:"selector,omitempty"`

pkg/crd/crds/backups-backuppolicy.schema.generated.yaml

@@ -18,7 +18,7 @@ v1:
               Parsed by https://godoc.org/github.com/robfig/cron
             type: string
           selector:
-            description: DeploymentSelector Selector definition for selecting matching ArangoBackup Custom Resources.
+            description: DeploymentSelector Selector definition for selecting matching ArangoDeployment Custom Resources.
             properties:
               matchExpressions:
                 items:

pkg/platform/flags.go

@@ -134,4 +134,10 @@ var (
 		Description: "List of insecure registries",
 		Default:     nil,
 	}
+
+	flagRegistryList = cli.Flag[[]string]{
+		Name:        "registry.docker.endpoint",
+		Description: "List of boosted registries",
+		Default:     nil,
+	}
 )

pkg/platform/package_export.go

@@ -34,7 +34,7 @@ func packageExport() (*cobra.Command, error) {
 	cmd.Use = "export [flags] package output"
 	cmd.Short = "Export the package in the ZIP Format"
 
-	if err := cli.RegisterFlags(&cmd, flagPlatformEndpoint, flagRegistryUseCredentials, flagRegistryInsecure); err != nil {
+	if err := cli.RegisterFlags(&cmd, flagPlatformEndpoint, flagRegistryUseCredentials, flagRegistryInsecure, flagRegistryList); err != nil {
 		return nil, err
 	}
 

pkg/platform/package_import.go

@@ -37,7 +37,7 @@ func packageImport() (*cobra.Command, error) {
 	cmd.Use = "import [flags] registry package output"
 	cmd.Short = "Imports the package from the ZIP format"
 
-	if err := cli.RegisterFlags(&cmd, flagRegistryUseCredentials, flagRegistryInsecure); err != nil {
+	if err := cli.RegisterFlags(&cmd, flagRegistryUseCredentials, flagRegistryInsecure, flagRegistryList); err != nil {
 		return nil, err
 	}
 

pkg/platform/regclient.go

@@ -35,6 +35,10 @@ func getRegClient(cmd *cobra.Command) (*regclient.RegClient, error) {
 
 	slog.SetLogLoggerLevel(slog.LevelDebug)
 
+	flags = append(flags, regclient.WithConfigHostDefault(config.Host{
+		ReqConcurrent: 8,
+	}))
+
 	flags = append(flags, regclient.WithRegOpts(reg.WithTransport(&goHttp.Transport{
 		MaxConnsPerHost: 64,
 		MaxIdleConns:    100,
@@ -55,6 +59,24 @@ func getRegClient(cmd *cobra.Command) (*regclient.RegClient, error) {
 		}
 
 		v.TLS = config.TLSDisabled
+		v.ReqConcurrent = 8
+
+		configs[el] = v
+	}
+
+	regs, err := flagRegistryList.Get(cmd)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, el := range regs {
+		v, ok := configs[el]
+		if !ok {
+			v.Name = el
+			v.Hostname = el
+		}
+
+		v.ReqConcurrent = 8
 
 		configs[el] = v
 	}