Add sync seconds for informer (#19)

Author: kairen

cmd/main.go

@@ -44,6 +44,7 @@ var (
 func parserFlags() {
 	flag.StringVarP(&kubeconfig, "kubeconfig", "", "", "Absolute path to the kubeconfig file.")
 	flag.IntVarP(&cfg.Threads, "threads", "", 2, "Number of worker threads used by the controller.")
+	flag.IntVarP(&cfg.SyncSec, "sync-seconds", "", 30, "Seconds for syncing and retrying objects.")
 	flag.StringSliceVarP(&cfg.IgnoreNamespaces, "ignore-namespaces", "", nil, "Ignore namespaces for syncing objects.")
 	flag.StringSliceVarP(&cfg.Services, "services", "", []string{"k8s-tcp", "k8s-udp"}, "The service objects of security policy.")
 	flag.StringSliceVarP(&cfg.SourceZones, "source-zones", "", []string{"untrust"}, "The source zones of security policy.")

pkg/config/types.go

@@ -18,8 +18,8 @@ package config
 
 // Config contains the operator config
 type Config struct {
-	Threads int
-
+	Threads          int
+	SyncSec          int
 	SourceZones      []string
 	SourceUsers      []string
 	HipProfiles      []string

pkg/operator/operator.go

@@ -50,8 +50,11 @@ func New(cfg *config.Config, clientset kubernetes.Interface, blendedset blended.
 		clientset:  clientset,
 		blendedset: blendedset,
 	}
-
-	o.informer = informers.NewSharedInformerFactory(clientset, defaultSyncTime)
+	t := defaultSyncTime
+	if cfg.SyncSec > 30 {
+		t = time.Second * time.Duration(cfg.SyncSec)
+	}
+	o.informer = informers.NewSharedInformerFactory(clientset, t)
 	o.service = service.NewController(cfg, clientset, blendedset, o.informer.Core().V1().Services())
 	o.namespace = namespace.NewController(cfg, clientset, blendedset, o.informer.Core().V1().Namespaces())
 	return o