Support limiting the container platfoms to sync

README.md

@@ -10,6 +10,7 @@ Sync chart packages and associated container images between chart repositories
     + [Sync all charts](#sync-all-helm-charts)
     + [Sync all charts from specific date](#sync-all-charts-from-specific-date)
 - [Advanced Usage](#advanced-usage)
+    + [Sync only specific container platforms](#sync-only-specific-container-platforms)
     + [Sync Helm Charts and Container Images to different registries](#sync-helm-charts-and-container-images-to-different-registries)
     + [Sync charts between repositories without direct connectivity](#sync-charts-between-repositories-without-direct-connectivity)
 - [Configuration](#configuration)
@@ -50,6 +51,32 @@ $ charts-syncer sync --latest-version-only
 
 ## Advanced Usage
 
+### Sync only specific container platforms
+
+By default, all container platforms are sync-ed to the destination registry, but this behavior can by tweaked by defining a list of platforms to sync:
+
+```yaml
+#
+# Example config file
+#
+source:
+  repo:
+    kind: OCI
+    url: http://localhost:8080
+target:
+  # Container images registry authn
+  repo:
+    kind: OCI
+    url: http://localhost:9090/charts
+
+containerPlatforms:
+  - linux/amd64
+
+charts:
+  - redis
+  - mariadb
+```
+
 ### Sync Helm Charts and Container Images to different registries
 
 By default, charts-syncer syncs Helm Charts packages and their container images to the same registry specified in the `target.repo.url` property. If you require to configure a different destination registry for the images, this can be configured in the `target.containers.url` property:

api/config.proto

@@ -9,6 +9,8 @@ message Config {
     Target target = 2;
     // Helm Charts to include during sync
     repeated string charts = 3;
+    // Container platforms to sync
+    repeated string container_platforms = 4;
     // Opposite of charts property. It indicates the list of charts to skip during sync
     repeated string skip_charts = 5;
 }

cmd/sync.go

@@ -103,6 +103,7 @@ func newSyncCmd() *cobra.Command {
 				syncer.WithDryRun(rootDryRun),
 				syncer.WithFromDate(syncFromDate),
 				syncer.WithWorkdir(syncWorkdir),
+				syncer.WithContainerPlatforms(c.GetContainerPlatforms()),
 				syncer.WithInsecure(rootInsecure),
 				syncer.WithLatestVersionOnly(syncLatestVersionOnly),
 				syncer.WithSkipCharts(c.SkipCharts),

pkg/client/config/config.go

@@ -8,8 +8,9 @@ import (
 
 // Config is the configuration object for the client package
 type Config struct {
-	Logger  log.SectionLogger
-	WorkDir string
+	Logger             log.SectionLogger
+	WorkDir            string
+	ContainerPlatforms []string
 }
 
 // Option is a function that modifies the Config
@@ -22,6 +23,13 @@ func WithWorkDir(workdir string) func(*Config) {
 	}
 }
 
+// WithContainerPlatforms sets the container platforms to sync
+func WithContainerPlatforms(containerPlatforms []string) func(*Config) {
+	return func(c *Config) {
+		c.ContainerPlatforms = containerPlatforms
+	}
+}
+
 // WithLogger sets the logger
 func WithLogger(logger log.SectionLogger) func(*Config) {
 	return func(c *Config) {

pkg/client/source/common/common.go

@@ -53,6 +53,7 @@ func (t *Source) Wrap(tgz, destWrap string, opts ...config.Option) (string, erro
 	outputFile, err := wrap.Chart(tgz, wrap.WithFetchArtifacts(true),
 		wrap.WithInsecure(t.insecure), wrap.WithTempDirectory(wrapWorkdir),
 		wrap.WithAuth(t.username, t.password),
+		wrap.WithPlatforms(cfg.ContainerPlatforms),
 		wrap.WithContainerRegistryAuth(t.containersUsername, t.containersPassword),
 		wrap.WithOutputFile(destWrap),
 		wrap.WithLogger(l))

pkg/syncer/sync.go

@@ -43,7 +43,7 @@ func (s *Syncer) syncChart(ch *Chart, l log.SectionLogger) error {
 
 	wrappedChartPath, err := s.cli.src.Wrap(ch.TgzPath,
 		filepath.Join(workdir, "wraps", fmt.Sprintf("%s-%s.wrap.tgz", ch.Name, ch.Version)),
-		config.WithLogger(l), config.WithWorkDir(workdir),
+		config.WithLogger(l), config.WithWorkDir(workdir), config.WithContainerPlatforms(s.containerPlatforms),
 	)
 	if err != nil {
 		return errors.Annotatef(err, "unable to move chart %q with charts-syncer", id)

pkg/syncer/syncer.go

@@ -39,6 +39,8 @@ type Syncer struct {
 	// list of charts to skip
 	skipCharts []string
 
+	// list of container platforms to sync
+	containerPlatforms []string
 	// TODO(jdrios): Cache index in local filesystem to speed
 	// up re-runs
 	index ChartIndex
@@ -164,3 +166,11 @@ func WithSkipCharts(charts []string) Option {
 		s.skipCharts = charts
 	}
 }
+
+// WithContainerPlatforms configures the syncer to sync chart containers for only
+// the specified list of platforms. Leaving a blank list syncs all.
+func WithContainerPlatforms(platforms []string) Option {
+	return func(s *Syncer) {
+		s.containerPlatforms = platforms
+	}
+}