in pkg/controller/controller.go [87:104]
func New(ctx context.Context, p *params) *controller {
return &controller{
clients: p.clients,
metrics: p.metrics,
healthCheck: p.healthCheck,
ingressQueue: workqueue.NewNamedRateLimitingQueue(
workqueue.DefaultControllerRateLimiter(), "ingressQueue"),
ingressResyncQueue: workqueue.NewNamedRateLimitingQueue(
workqueue.DefaultControllerRateLimiter(), "ingressResyncQueue"),
managedCertificateQueue: workqueue.NewNamedRateLimitingQueue(
workqueue.DefaultControllerRateLimiter(), "managedCertificateQueue"),
managedCertificateResyncQueue: workqueue.NewNamedRateLimitingQueue(
workqueue.DefaultControllerRateLimiter(), "managedCertificateResyncQueue"),
resyncInterval: p.resyncInterval,
state: p.state,
sync: p.sync,
}
}