98
}
99
100
>
func (ni *NamespaceRateLimitInterceptorImpl) Wait(ctx context.Context, namespaceName namespace.Name, methodName string, headerGetter headers.HeaderGetter) error {
namespace_rate_limit.go
101
>
token, ok := ni.tokens[methodName]
102
>
if !ok {
103
>
token = NamespaceRateLimitDefaultToken
104
>
}
105
>
request := quotas.NewRequest(
106
>
methodName,
107
>
token,
108
>
namespaceName.String(),
109
>
headerGetter.Get(headers.CallerTypeHeaderName),
110
>
0, // this interceptor layer does not throttle based on caller segment
111
>
"", // this interceptor layer does not throttle based on call initiation
112
>
)
113
>
114
>
if ni.rateLimiter.Allow(time.Now().UTC(), request) {
115
return nil
116
}