[operator] fix kube clientcmd util

apache · Dec 8, 2024 · f6643bc · f6643bc
1 parent 690a0fa
commit f6643bc
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 17 deletions.
diff --git a/dubboctl/pkg/cli/context.go b/dubboctl/pkg/cli/context.go
@@ -3,6 +3,7 @@ package cli
 import (
 	"github.com/apache/dubbo-kubernetes/pkg/kube"
 	"github.com/apache/dubbo-kubernetes/pkg/pointer"
+	"k8s.io/client-go/rest"
 )
 
 type instance struct {
@@ -41,5 +42,12 @@ func (i *instance) CLIClientWithRevision(rev string) (kube.CLIClient, error) {
 }
 
 func newKubeClientWithRevision(kubeconfig, context, revision string) (kube.CLIClient, error) {
+	drc, err := kube.DefaultRestConfig(kubeconfig, context, func(config *rest.Config) {
+		config.QPS = 50
+		config.Burst = 100
+	})
+	if err != nil {
+		return nil, err
+	}
 	return nil, nil
 }
diff --git a/pkg/kube/client.go b/pkg/kube/client.go
@@ -26,7 +26,8 @@ type CLIClient interface {
 
 type ClientOption func(cliClient CLIClient) CLIClient
 
-func NewClientClient(clientCfg clientcmd.ClientConfig) (CLIClient, error) {
+func NewCLIClient(clientCfg clientcmd.ClientConfig, opts ...ClientOption) (CLIClient, error) {
+
 	return nil, nil
 }
 

diff --git a/pkg/util/kube/util.go → pkg/kube/util.go b/pkg/util/kube/util.go → pkg/kube/util.go
@@ -5,7 +5,6 @@ import (
 	"k8s.io/apimachinery/pkg/runtime/serializer"
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
-
 	"os"
 )
 

diff --git a/pkg/util/kube/client.go b/pkg/util/kube/client.go
-Original file line number
+Diff line change
@@ Expand Up / @@ -5,7 +5,6 @@ import ( @@
     	"k8s.io/apimachinery/pkg/runtime/serializer"
     	"k8s.io/client-go/rest"
     	"k8s.io/client-go/tools/clientcmd"
     	"os"
     )
@@ Expand Down @@