sarapprover: increase base delay of per item rate limit

from 5 miliseconds to 1 second
This commit is contained in:
Mike Danese 2017-10-13 11:48:17 -07:00
parent 302fe7c0c8
commit 0e0f8346e7

View File

@ -36,6 +36,7 @@ import (
"k8s.io/kubernetes/pkg/controller"
"github.com/golang/glog"
"github.com/juju/ratelimit"
)
type CertificateController struct {
@ -61,8 +62,12 @@ func NewCertificateController(
cc := &CertificateController{
kubeClient: kubeClient,
queue: workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "certificate"),
handler: handler,
queue: workqueue.NewNamedRateLimitingQueue(workqueue.NewMaxOfRateLimiter(
workqueue.NewItemExponentialFailureRateLimiter(200*time.Millisecond, 1000*time.Second),
// 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item)
&workqueue.BucketRateLimiter{Bucket: ratelimit.NewBucketWithRate(float64(10), int64(100))},
), "certificate"),
handler: handler,
}
// Manage the addition/update of certificate requests