add switch for compact (#3336)

* add switch for compact
kubeovn · Oct 25, 2023 · 49061ce · 49061ce
1 parent 1fe0a99
commit 49061ce
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/dist/images/start-db.sh b/dist/images/start-db.sh
@@ -23,6 +23,8 @@ cat /proc/cmdline"
     exit 1
 fi
 
+PRBOE_INTERVAL=${PRBOE_INTERVAL:-5}
+ENABLE_COMPACT=${ENABLE_COMPACT:-false}
 DB_NB_ADDR=${DB_NB_ADDR:-::}
 DB_NB_PORT=${DB_NB_PORT:-6641}
 DB_SB_ADDR=${DB_SB_ADDR:-::}
@@ -366,5 +368,5 @@ ovs-appctl -t /var/run/ovn/ovnnb_db.ctl ovsdb-server/memory-trim-on-compaction o
 ovs-appctl -t /var/run/ovn/ovnsb_db.ctl ovsdb-server/memory-trim-on-compaction on
 
 chmod 600 /etc/ovn/*
-/kube-ovn/kube-ovn-leader-checker
+/kube-ovn/kube-ovn-leader-checker --probeInterval=$PRBOE_INTERVAL --enableCompact=$ENABLE_COMPACT
 
diff --git a/pkg/ovn_leader_checker/ovn.go b/pkg/ovn_leader_checker/ovn.go
@@ -43,6 +43,7 @@ type Configuration struct {
 	KubeConfigFile string
 	KubeClient     kubernetes.Interface
 	ProbeInterval  int
+	EnableCompact  bool
 }
 
 // ParseFlags parses cmd args then init kubeclient and conf
@@ -51,6 +52,7 @@ func ParseFlags() (*Configuration, error) {
 	var (
 		argKubeConfigFile = pflag.String("kubeconfig", "", "Path to kubeconfig file with authorization and master location information. If not set use the inCluster token.")
 		argProbeInterval  = pflag.Int("probeInterval", DefaultProbeInterval, "interval of probing leader in seconds")
+		argEnableCompact  = pflag.Bool("enableCompact", true, "is enable compact")
 	)
 
 	klogFlags := flag.NewFlagSet("klog", flag.ContinueOnError)
@@ -80,6 +82,7 @@ func ParseFlags() (*Configuration, error) {
 	config := &Configuration{
 		KubeConfigFile: *argKubeConfigFile,
 		ProbeInterval:  *argProbeInterval,
+		EnableCompact:  *argEnableCompact,
 	}
 	return config, nil
 }
@@ -379,8 +382,11 @@ func doOvnLeaderCheck(cfg *Configuration, podName string, podNamespace string) {
 			stealLock()
 		}
 	}
-	compactOvnDatabase("nb")
-	compactOvnDatabase("sb")
+
+	if cfg.EnableCompact {
+		compactOvnDatabase("nb")
+		compactOvnDatabase("sb")
+	}
 }
 
 func StartOvnLeaderCheck(cfg *Configuration) {