()
| 102 | } |
| 103 | |
| 104 | func getDefaultOptions() controller.Options { |
| 105 | optionsInit.Do(func() { |
| 106 | defaultOptions = &controller.Options{ |
| 107 | RateLimiter: workqueue.NewTypedItemExponentialFailureRateLimiter[k8sreconcile.Request](2*time.Second, 2*time.Minute), |
| 108 | CacheSyncTimeout: *cacheSyncTimeout, |
| 109 | MaxConcurrentReconciles: *maxConcurrency, |
| 110 | } |
| 111 | }) |
| 112 | return *defaultOptions |
| 113 | } |
| 114 | |
| 115 | // ErrShutdown is a custom error returned as a cause of operator context cancel |
| 116 | var ErrShutdown = fmt.Errorf("graceful shutdown, exiting") |
no outgoing calls
no test coverage detected