140
}
141
142
>
func (ni *NamespaceRateLimitInterceptorImpl) Allow(namespaceName namespace.Name, methodName string, headerGetter headers.HeaderGetter) error {
namespace_rate_limit.go
143
>
token, ok := ni.tokens[methodName]
144
>
if !ok {
145
>
token = NamespaceRateLimitDefaultToken
146
>
}
147
149
>
methodName,
150
>
token,
151
>
namespaceName.String(),
152
>
headerGetter.Get(headers.CallerTypeHeaderName),
153
>
0, // this interceptor layer does not throttle based on caller segment
154
>
"", // this interceptor layer does not throttle based on call initiation
155
>
)) {
156
return ErrNamespaceRateLimitServerBusy
157
}