increase cache sync timeouts (#558)

Author: maciaszczykm

cmd/agent/kubernetes.go

@@ -287,18 +287,20 @@ func registerKubeReconcilersOrDie(
 		setupLog.Error(err, "unable to create controller", "controller", "AgentConfiguration")
 	}
 	if err := (&controller.AgentRuntimeReconciler{
-		Client:        manager.GetClient(),
-		Scheme:        manager.GetScheme(),
-		ConsoleClient: extConsoleClient,
+		Client:           manager.GetClient(),
+		Scheme:           manager.GetScheme(),
+		ConsoleClient:    extConsoleClient,
+		CacheSyncTimeout: args.PollInterval() * 3,
 	}).SetupWithManager(manager); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "AgentRuntime")
 	}
 	if err := (&controller.AgentRunReconciler{
-		Client:        manager.GetClient(),
-		Scheme:        manager.GetScheme(),
-		ConsoleClient: extConsoleClient,
-		ConsoleURL:    consoleURL,
-		DeployToken:   deployToken,
+		Client:           manager.GetClient(),
+		Scheme:           manager.GetScheme(),
+		ConsoleClient:    extConsoleClient,
+		ConsoleURL:       consoleURL,
+		DeployToken:      deployToken,
+		CacheSyncTimeout: args.PollInterval() * 3,
 	}).SetupWithManager(manager); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "AgentRun")
 	}

internal/controller/agentrun_controller.go

@@ -46,16 +46,17 @@ const (
 // 3. Reporting status back to Console API
 type AgentRunReconciler struct {
 	client.Client
-	Scheme        *runtime.Scheme
-	ConsoleClient pluralclient.Client
-	ConsoleURL    string
-	DeployToken   string
+	Scheme           *runtime.Scheme
+	ConsoleClient    pluralclient.Client
+	ConsoleURL       string
+	DeployToken      string
+	CacheSyncTimeout time.Duration
 }
 
 // SetupWithManager configures the controller with the manager.
 func (r *AgentRunReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		WithOptions(controller.Options{MaxConcurrentReconciles: 1}).
+		WithOptions(controller.Options{MaxConcurrentReconciles: 1, CacheSyncTimeout: r.CacheSyncTimeout}).
 		For(&v1alpha1.AgentRun{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
 		Owns(&corev1.Pod{}).
 		Complete(r)

internal/controller/agentruntime_controller.go

@@ -33,8 +33,9 @@ const (
 // AgentRuntimeReconciler reconciles a AgentRuntime object
 type AgentRuntimeReconciler struct {
 	client.Client
-	ConsoleClient consoleclient.Client
-	Scheme        *runtime.Scheme
+	ConsoleClient    consoleclient.Client
+	Scheme           *runtime.Scheme
+	CacheSyncTimeout time.Duration
 }
 
 //+kubebuilder:rbac:groups=deployments.plural.sh,resources=agentruntimes,verbs=get;list;watch;create;update;patch;delete
@@ -124,7 +125,7 @@ func (r *AgentRuntimeReconciler) Reconcile(ctx context.Context, req ctrl.Request
 // SetupWithManager sets up the controller with the Manager.
 func (r *AgentRuntimeReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
-		WithOptions(controller.Options{MaxConcurrentReconciles: 1}).
+		WithOptions(controller.Options{MaxConcurrentReconciles: 1, CacheSyncTimeout: r.CacheSyncTimeout}).
 		For(&v1alpha1.AgentRuntime{}, builder.WithPredicates(predicate.GenerationChangedPredicate{})).
 		Complete(r)
 }