add resync-option for operatorkit (#518)

* add resync-option for operatorkit

CHANGELOG.md

@@ -7,6 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+
+- Added `--service.controller.resyncperiod` daemon flag that can be controller via `.controller.resyncPeriod` Helm value.
+  Controls the duration after which a complete sync with all known runtime objects the controller watches is performed.
+  Defaults to `5m`.
+
 ## [2.22.0] - 2024-05-03
 
 ### Added

flag/service/controller/controller.go

@@ -0,0 +1,5 @@
+package controller
+
+type Controller struct {
+	ResyncPeriod string
+}

flag/service/service.go

@@ -4,6 +4,7 @@ import (
 	"github.com/giantswarm/operatorkit/v7/pkg/flag/service/kubernetes"
 
 	"github.com/giantswarm/cluster-apps-operator/v2/flag/service/app"
+	"github.com/giantswarm/cluster-apps-operator/v2/flag/service/controller"
 	"github.com/giantswarm/cluster-apps-operator/v2/flag/service/image"
 	"github.com/giantswarm/cluster-apps-operator/v2/flag/service/proxy"
 	"github.com/giantswarm/cluster-apps-operator/v2/flag/service/workload"
@@ -16,4 +17,6 @@ type Service struct {
 	Kubernetes kubernetes.Kubernetes
 	Workload   workload.Workload
 	Proxy      proxy.Proxy
+
+	Controller controller.Controller
 }

helm/cluster-apps-operator/templates/configmap.yaml

@@ -24,6 +24,8 @@ data:
       image:
         registry:
           domain: {{ .Values.registry.domain }}
+      controller:
+        resyncPeriod: '{{ .Values.controller.resyncPeriod }}'
       kubernetes:
         address: ''
         inCluster: true

helm/cluster-apps-operator/values.yaml

@@ -35,6 +35,9 @@ image:
   name: "giantswarm/cluster-apps-operator"
   tag: "[[ .Version ]]"
 
+controller:
+  resyncPeriod: "5m"
+
 kubernetes:
   api:
     clusterIPRange: 10.96.0.0/12

main.go

@@ -107,6 +107,7 @@ func mainE(ctx context.Context) error {
 	daemonCommand.PersistentFlags().String(f.Service.App.ChartOperator.Version, "", "Version for chart-operator app CR.")
 
 	daemonCommand.PersistentFlags().String(f.Service.Image.Registry.Domain, "quay.io", "Image registry.")
+	daemonCommand.PersistentFlags().String(f.Service.Controller.ResyncPeriod, "5m", "Duration after which a complete sync with all known cluster-objects the controller watches is performed.")
 
 	daemonCommand.PersistentFlags().String(f.Service.Kubernetes.Address, "http://127.0.0.1:6443", "Address used to connect to Kubernetes. When empty in-cluster config is created.")
 	daemonCommand.PersistentFlags().Bool(f.Service.Kubernetes.InCluster, false, "Whether to use the in-cluster config to authenticate with Kubernetes.")

service/controller/cluster.go

@@ -1,6 +1,8 @@
 package controller
 
 import (
+	"time"
+
 	"github.com/giantswarm/k8sclient/v7/pkg/k8sclient"
 	"github.com/giantswarm/k8smetadata/pkg/label"
 	"github.com/giantswarm/microerror"
@@ -25,9 +27,10 @@ import (
 )
 
 type ClusterConfig struct {
-	K8sClient k8sclient.Interface
-	Logger    micrologger.Logger
-	PodCIDR   podcidr.Interface
+	K8sClient    k8sclient.Interface
+	Logger       micrologger.Logger
+	PodCIDR      podcidr.Interface
+	ResyncPeriod time.Duration
 
 	AppOperatorCatalog   string
 	AppOperatorVersion   string
@@ -68,6 +71,8 @@ func NewCluster(config ClusterConfig) (*Cluster, error) {
 			},
 			Resources: resources,
 
+			ResyncPeriod: config.ResyncPeriod,
+
 			// Name is used to compute finalizer names. This here results in something
 			// like operatorkit.giantswarm.io/cluster-apps-operator-cluster-controller.
 			Name:     project.Name() + "-cluster-controller",

service/service.go

@@ -142,6 +142,8 @@ func New(config Config) (*Service, error) {
 			Logger:    config.Logger,
 			PodCIDR:   pc,
 
+			ResyncPeriod: config.Viper.GetDuration(config.Flag.Service.Controller.ResyncPeriod),
+
 			AppOperatorCatalog:   config.Viper.GetString(config.Flag.Service.App.AppOperator.Catalog),
 			AppOperatorVersion:   config.Viper.GetString(config.Flag.Service.App.AppOperator.Version),
 			ChartOperatorCatalog: config.Viper.GetString(config.Flag.Service.App.ChartOperator.Catalog),