[backplane] preload + default to the latest envoy image

Author: theRealWardo

ci/main.go

@@ -287,6 +287,15 @@ func (m *ApoxyCli) BuildBackplane(
 WithFile("/bin/backplane", builder.File(bpOut)).
 WithFile("/bin/dial-stdio", builder.File(dsOut)).
 WithFile("/bin/edge-runtime", runtimeCtr.File("/usr/local/bin/edge-runtime")).
+WithExec([]string{
+"/bin/backplane",
+"--project_id=apoxy",
+"--proxy=apoxy",
+"--replica=apoxy",
+"--apiserver_addr=localhost:8443",
+"--use_envoy_contrib=true",
+"--download_envoy_only=true",
+}).
 WithEntrypoint([]string{"/bin/backplane"})
 }
 

cmd/backplane/main.go

@@ -60,6 +60,7 @@ var (
 proxyName = flag.String("proxy", "", "Name of the Proxy to manage. Must not be used with --proxy_path.")
 replicaName = flag.String("replica", os.Getenv("HOSTNAME"), "Name of the replica to manage.")
 envoyReleaseURL = flag.String("envoy_release_url", "", "URL to the Envoy release tarball.")
+downloadEnvoy = flag.Bool("download_envoy_only", false, "Whether to just download Envoy from the release URL and exit.")
 
 devMode = flag.Bool("dev", false, "Enable development mode.")
 
@@ -290,6 +291,12 @@ func main() {
 apiServerHost,
 proxyOpts...,
 )
+if *downloadEnvoy {
+if err := pctrl.DownloadEnvoy(ctx); err != nil {
+log.Fatalf("Failed to download Envoy: %v", err)
+}
+os.Exit(0)
+}
 if err := pctrl.SetupWithManager(ctx, mgr); err != nil {
 log.Fatalf("failed to set up Backplane controller: %v", err)
 }

pkg/backplane/controllers/proxy.go

@@ -491,6 +491,29 @@ func (r *ProxyReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager
 Complete(r)
 }
 
+func (r *ProxyReconciler) DownloadEnvoy(ctx context.Context) error {
+opts := []envoy.Option{
+envoy.WithGoPluginDir(r.options.goPluginDir),
+}
+if r.options.releaseURL != "" {
+opts = append(opts, envoy.WithRelease(&envoy.URLRelease{
+URL: r.options.releaseURL,
+}))
+} else {
+opts = append(opts, envoy.WithRelease(&envoy.GitHubRelease{
+Contrib: r.options.useEnvoyContrib,
+}))
+}
+
+if err := r.Runtime.Start(ctx, opts...); err != nil {
+return fmt.Errorf("failed to start Envoy runtime: %w", err)
+}
+if err := r.Runtime.Shutdown(ctx); err != nil {
+return fmt.Errorf("failed to shutdown Envoy runtime: %w", err)
+}
+return nil
+}
+
 func (r *ProxyReconciler) Shutdown(ctx context.Context, reason string) {
 var wg sync.WaitGroup
 wg.Add(2)

pkg/backplane/drivers/docker.go

@@ -12,7 +12,6 @@ import (
 
 "github.com/apoxy-dev/apoxy-cli/build"
 "github.com/apoxy-dev/apoxy-cli/pkg/log"
-"github.com/apoxy-dev/apoxy-cli/pkg/utils"
 dockerutils "github.com/apoxy-dev/apoxy-cli/pkg/utils/docker"
 )
 
@@ -133,7 +132,6 @@ func (d *dockerDriver) Start(
 "--proxy=" + proxyName,
 "--replica=" + proxyName,
 "--apiserver_addr=" + net.JoinHostPort(apiServerHost, "8443"),
-"--envoy_release_url=https://apoxy-envoy-releases.s3.us-west-2.amazonaws.com/envoy-contrib-dev-cfedcdbc0bf1e687d0fc2ad243e7277ed004673d-" + utils.HostArch(),
 "--use_envoy_contrib=true",
 }...)
 cmd.Args = append(cmd.Args, setOpts.Args...)