574
namespaceRateLimiter := quotas.NewNamespaceRequestRateLimiter(
575
func(req quotas.Request) quotas.RequestRateLimiter {
576
>
return configs.NewRequestToRateLimiter(
fx.go
577
>
quotas.NewNamespaceRateBurst(
578
>
req.Caller,
579
>
namespaceRateFn,
580
>
quotas.NamespaceBurstRatioFn(serviceConfig.MaxNamespaceBurstRatioPerInstance),
581
>
),
582
>
quotas.NewNamespaceRateBurst(
583
>
req.Caller,
584
>
visibilityRateFn,
585
>
quotas.NamespaceBurstRatioFn(serviceConfig.MaxNamespaceVisibilityBurstRatioPerInstance),
586
>
),
587
>
quotas.NewNamespaceRateBurst(
588
>
req.Caller,
589
>
namespaceReplicationInducingRateFn,
590
>
quotas.NamespaceBurstRatioFn(serviceConfig.MaxNamespaceNamespaceReplicationInducingAPIsBurstRatioPerInstance),
591
>
),
592
>
serviceConfig.OperatorRPSRatio,
593
>
)
594
>
},
595
)
596
return interceptor.NewNamespaceRateLimitInterceptor(