fluxcd
/
source-controller
mirror of https://github.com/fluxcd/source-controller.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Implementing RecoverPanic on reconcilers to ensure it recovers from panic instead of crashing the controller and Squashed commits. 

Signed-off-by: Santosh Kaluskar <dtshbl@gmail.com>
This commit is contained in:
Santosh Kaluskar 2022-08-09 19:33:15 +05:30
parent 02ff549924
commit 1ad2f004ac
6 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
controllers/bucket_controller.go
View File

@ -241,6 +241,7 @@ func (r *BucketReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts Buc
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }

1
controllers/gitrepository_controller.go
View File

@ -156,6 +156,7 @@ func (r *GitRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, o
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }

1
controllers/helmchart_controller.go
View File

@ -176,6 +176,7 @@ func (r *HelmChartReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, opts
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }

1
controllers/helmrepository_controller.go
View File

@ -142,6 +142,7 @@ func (r *HelmRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager,
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }

1
controllers/helmrepository_controller_oci.go
View File

@ -102,6 +102,7 @@ func (r *HelmRepositoryOCIReconciler) SetupWithManagerAndOptions(mgr ctrl.Manage
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }

1
controllers/ocirepository_controller.go
View File

@ -147,6 +147,7 @@ func (r *OCIRepositoryReconciler) SetupWithManagerAndOptions(mgr ctrl.Manager, o
WithOptions(controller.Options{ WithOptions(controller.Options{
MaxConcurrentReconciles: opts.MaxConcurrentReconciles, MaxConcurrentReconciles: opts.MaxConcurrentReconciles,
RateLimiter: opts.RateLimiter, RateLimiter: opts.RateLimiter,
RecoverPanic: true,
}). }).
Complete(r) Complete(r)
} }