Add flush interval

acorn-io · Jul 1, 2022 · c0901fe · c0901fe
1 parent 1b11147
commit c0901fe
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 7 deletions.
diff --git a/pkg/server/registry/builders/port.go b/pkg/server/registry/builders/port.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/http/httputil"
+	"time"
 
 	apiv1 "github.com/acorn-io/acorn/pkg/apis/api.acorn.io/v1"
 	"github.com/acorn-io/acorn/pkg/build/buildkit"
@@ -46,8 +47,9 @@ func NewBuildkitPort(client client.WithWatch, builders *Storage, cfg *clientgo.C
 		client:   client,
 		builders: builders,
 		proxy: httputil.ReverseProxy{
-			Transport: transport,
-			Director:  func(request *http.Request) {},
+			FlushInterval: 200 * time.Millisecond,
+			Transport:     transport,
+			Director:      func(request *http.Request) {},
 		},
 		RESTClient: k8s.CoreV1().RESTClient(),
 	}, nil

diff --git a/pkg/server/registry/builders/registryport.go b/pkg/server/registry/builders/registryport.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/http/httputil"
+	"time"
 
 	apiv1 "github.com/acorn-io/acorn/pkg/apis/api.acorn.io/v1"
 	"github.com/acorn-io/acorn/pkg/build/buildkit"
@@ -46,8 +47,9 @@ func NewRegistryPort(client client.WithWatch, builders *Storage, cfg *clientgo.C
 		client:   client,
 		builders: builders,
 		proxy: httputil.ReverseProxy{
-			Transport: transport,
-			Director:  func(request *http.Request) {},
+			FlushInterval: 200 * time.Millisecond,
+			Transport:     transport,
+			Director:      func(request *http.Request) {},
 		},
 		RESTClient: k8s.CoreV1().RESTClient(),
 	}, nil

diff --git a/pkg/server/registry/containers/exec.go b/pkg/server/registry/containers/exec.go
@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/http/httputil"
+	"time"
 
 	apiv1 "github.com/acorn-io/acorn/pkg/apis/api.acorn.io/v1"
 	"github.com/acorn-io/acorn/pkg/watcher"
@@ -57,8 +58,9 @@ func NewContainerExec(client client.WithWatch, containers *Storage, cfg *clientg
 		client:     client,
 		containers: containers,
 		proxy: httputil.ReverseProxy{
-			Transport: transport,
-			Director:  func(request *http.Request) {},
+			FlushInterval: 200 * time.Millisecond,
+			Transport:     transport,
+			Director:      func(request *http.Request) {},
 		},
 		RESTClient: k8s.CoreV1().RESTClient(),
 	}, nil

diff --git a/pkg/system/constants.go b/pkg/system/constants.go
@@ -12,7 +12,7 @@ var (
 	RegistryName   = "registry"
 	RegistryImage  = "registry:2.7.1"
 	RegistryPort   = 5000
-	BuildkitImage  = "moby/buildkit:master"
+	BuildkitImage  = "moby/buildkit:v0.10.3"
 	BuildKitName   = "buildkitd"
 	ControllerName = "acorn-controller"
 	APIServerName  = "acorn-api"