[feat] ability to customize kube client qps

main.go

@@ -1,6 +1,8 @@
 package main
 
 import (
+	"flag"
+
 	"github.com/argoproj-labs/rollouts-plugin-trafficrouter-gatewayapi/internal/utils"
 	"github.com/argoproj-labs/rollouts-plugin-trafficrouter-gatewayapi/pkg/plugin"
 
@@ -19,12 +21,24 @@ var handshakeConfig = goPlugin.HandshakeConfig{
 }
 
 func main() {
+	// Define and parse flags for your new command line options:
+	kubeClientQPS := flag.Int("kubeClientQPS", 5, "The QPS to use for the Kubernetes client.")
+	kubeClientBurst := flag.Int("kubeClientBurst", 10, "The Burst to use for the Kubernetes client.")
+	flag.Parse()
+
+	// Create the plugin implementation, injecting your command line options:
 	rpcPluginImp := &plugin.RpcPlugin{
+		CommandLineOpts: plugin.CommandLineOpts{
+			KubeClientQPS:   float32(*kubeClientQPS),
+			KubeClientBurst: *kubeClientBurst,
+		},
 		LogCtx: utils.SetupLog(),
 	}
+
 	pluginMap := map[string]goPlugin.Plugin{
 		"RpcTrafficRouterPlugin": &rolloutsPlugin.RpcTrafficRouterPlugin{Impl: rpcPluginImp},
 	}
+
 	goPlugin.Serve(&goPlugin.ServeConfig{
 		HandshakeConfig: handshakeConfig,
 		Plugins:         pluginMap,

pkg/plugin/types.go

@@ -13,7 +13,13 @@ import (
 	gatewayApiClientv1alpha2 "sigs.k8s.io/gateway-api/pkg/client/clientset/versioned/typed/apis/v1alpha2"
 )
 
+type CommandLineOpts struct {
+	KubeClientQPS   float32
+	KubeClientBurst int
+}
+
 type RpcPlugin struct {
+	CommandLineOpts      CommandLineOpts
 	HTTPRouteClient      gatewayApiClientv1.HTTPRouteInterface
 	TCPRouteClient       gatewayApiClientv1alpha2.TCPRouteInterface
 	GRPCRouteClient      gatewayApiClientv1.GRPCRouteInterface