[PLAT-6701] Enable zstd hephaestus

pkg/buildkit/buildkit.go

@@ -23,6 +23,7 @@ import (
 	"k8s.io/apimachinery/pkg/util/wait"
 
 	"github.com/dominodatalab/hephaestus/pkg/buildkit/archive"
+	hephconfig "github.com/dominodatalab/hephaestus/pkg/config"
 )
 
 var clientCheckBackoff = wait.Backoff{ // retries after 500ms 1s 2s 4s 8s 16s 32s 64s with jitter
@@ -122,6 +123,27 @@ type Client struct {
 	dockerConfigDir string
 }
 
+func validateCompression(compression string, name string) map[string]string {
+	attrs := make(map[string]string)
+	attrs["name"] = name
+	const truth = "true"
+	switch compression {
+	case "estargz":
+		attrs["push"] = truth
+		attrs["compression"] = "estargz"
+		attrs["force-compression"] = truth
+		attrs["oci-mediatypes"] = truth
+	case "zstd":
+		attrs["compression"] = "zstd"
+		attrs["force-compression"] = truth
+		attrs["push"] = truth
+	// default is gzip
+	default:
+		attrs["push"] = truth
+	}
+	return attrs
+}
+
 func (c *Client) Build(ctx context.Context, opts BuildOptions) error {
 	// setup build directory
 	buildDir, err := os.MkdirTemp("", "hephaestus-build-")
@@ -241,14 +263,11 @@ func (c *Client) Build(ctx context.Context, opts BuildOptions) error {
 			solveOpt.FrontendAttrs[k] = v
 		}
 	}
-
 	for _, name := range opts.Images {
+		bkclientattrs := validateCompression(hephconfig.CompressionMethod, name)
 		solveOpt.Exports = append(solveOpt.Exports, bkclient.ExportEntry{
-			Type: bkclient.ExporterImage,
-			Attrs: map[string]string{
-				"name": name,
-				"push": "true",
-			},
+			Type:  bkclient.ExporterImage,
+			Attrs: bkclientattrs,
 		})
 	}
 

pkg/cmd/controller/root.go

@@ -2,6 +2,7 @@ package controller
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/spf13/cobra"
 
@@ -17,7 +18,10 @@ func NewCommand() *cobra.Command {
 		Use:   "hephaestus-controller",
 		Short: "OCI image build controller using buildkit",
 	}
-	cmd.PersistentFlags().StringVarP(&cfgFile, "config", "c", "hephaestus.yaml", "configuration file")
+	cmd.PersistentFlags().StringVarP(&cfgFile, "config", "c",
+		"hephaestus.yaml", "configuration file")
+	cmd.PersistentFlags().StringVarP(&config.CompressionMethod,
+		"compression", "d", "gzip", "Compression method options: zstd,estargz")
 	cmd.AddCommand(
 		newStartCommand(),
 		newRunGCCommand(),
@@ -33,6 +37,8 @@ func newStartCommand() *cobra.Command {
 		Use:   "start",
 		Short: "Start controller",
 		RunE: func(cmd *cobra.Command, _ []string) error {
+			config.CompressionMethod, _ = cmd.Flags().GetString("compression")
+			fmt.Printf("BuildKit compression method: %s enabled\n", config.CompressionMethod)
 			cfgFile, err := cmd.Flags().GetString("config")
 			if err != nil {
 				return err

pkg/config/config.go

@@ -12,6 +12,8 @@ import (
 	"gopkg.in/yaml.v3"
 )
 
+var CompressionMethod string
+
 type Controller struct {
 	Logging   Logging   `json:"logging" yaml:"logging"`
 	Manager   Manager   `json:"manager" yaml:"manager"`