feat: add Redis Proxy disable option for test environment (#607)

Signed-off-by: yeonsoo <[email protected]>

Author: juanxiu

principal/options.go

@@ -75,6 +75,7 @@ type ServerOptions struct {
 	redisPassword          string
 	redisCompressionType   cacheutil.RedisCompressionType
 	healthzPort            int
+	redisProxyDisabled     bool
 	informerSyncTimeout    time.Duration
 }
 
@@ -417,6 +418,14 @@ func WithWebSocket(enableWebSocket bool) ServerOption {
 	}
 }
 
+// WithRedisProxyDisabled disables the Redis proxy for testing.
+func WithRedisProxyDisabled() ServerOption {
+	return func(o *Server) error {
+		o.options.redisProxyDisabled = true
+		return nil
+	}
+}
+
 // WithInformerSyncTimeout sets the informer sync timeout duration.
 func WithInformerSyncTimeout(timeout time.Duration) ServerOption {
 	return func(o *Server) error {

principal/options_test.go

@@ -98,3 +98,10 @@ func Test_WithMinimumTLSVersion(t *testing.T) {
 		}
 	})
 }
+
+func Test_WithRedisProxyDisabled(t *testing.T) {
+	s := &Server{options: &ServerOptions{}}
+	err := WithRedisProxyDisabled()(s)
+	assert.NoError(t, err)
+	assert.True(t, s.options.redisProxyDisabled)
+}

principal/server.go

@@ -337,7 +337,9 @@ func NewServer(ctx context.Context, kubeClient *kube.KubernetesClient, namespace
 		s.resourceProxyListenAddr = defaultResourceProxyListenerAddr
 	}
 
-	s.redisProxy = redisproxy.New(defaultRedisProxyListenerAddr, s.options.redisAddress, s.sendSynchronousRedisMessageToAgent)
+	if !s.options.redisProxyDisabled {
+		s.redisProxy = redisproxy.New(defaultRedisProxyListenerAddr, s.options.redisAddress, s.sendSynchronousRedisMessageToAgent)
+	}
 
 	// Instantiate our ResourceProxy to intercept Kubernetes requests from Argo
 	// CD's API server.