50
globalQuota func(ns string) int,
51
tokens map[string]int,
53
>
return &ConcurrentRequestLimitInterceptor{
54
>
namespaceRegistry: namespaceRegistry,
55
>
logger: logger,
56
>
quotaCalculator: calculator.NewLoggedNamespaceCalculator(
57
>
calculator.ClusterAwareNamespaceQuotaCalculator{
58
>
MemberCounter: memberCounter,
59
>
PerInstanceQuota: perInstanceQuota,
60
>
GlobalQuota: globalQuota,
61
>
},
62
>
log.With(logger, tag.ComponentLongPollHandler, tag.ScopeNamespace),
63
>
),
64
>
tokens: tokens,
65
>
activeTokensCount: make(map[string]*int32),
66
>
}
67
>
}
68
69
func (ni *ConcurrentRequestLimitInterceptor) Intercept(