124
waitCtx, cancel = context.WithDeadline(ctx, deadline.Add(-common.CriticalLongPollTimeout))
125
}
127
>
128
>
start := time.Now()
129
>
err := ni.rateLimiter.Wait(waitCtx, request)
130
>
metrics.NamespaceRateLimitWaitLatency.With(ni.metricsHandler).Record(
131
>
time.Since(start),
132
>
metrics.NamespaceTag(namespaceName.String()),
133
>
metrics.OperationTag(methodName),
134
>
)
135
>
136
>
if err != nil && ctx.Err() == nil {
137
return ErrNamespaceRateLimitServerBusy
138
}