6480
}
6481
6482
>
func (wh *WorkflowHandler) checkWorkerDeploymentReadRateLimit(ctx context.Context, namespaceName, apiName string) error {
workflow_handler.go
6483
>
callerInfo := headers.GetCallerInfo(ctx)
6484
>
req := quotas.NewRequest(
6485
>
apiName,
6486
>
1,
6487
>
namespaceName,
6488
>
callerInfo.CallerType,
6489
>
-1,
6490
>
callerInfo.CallOrigin,
6491
>
)
6492
>
6493
>
if !wh.workerDeploymentReadRateLimiter.Allow(time.Now().UTC(), req) {
6494
>
return &serviceerror.ResourceExhausted{
6495
>
Cause: enumspb.RESOURCE_EXHAUSTED_CAUSE_RPS_LIMIT,
6496
>
Scope: enumspb.RESOURCE_EXHAUSTED_SCOPE_NAMESPACE,
6497
>
Message: fmt.Sprintf("Worker Deployment Read API rate limit exceeded for namespace %q", namespaceName),
6498
>
}
6499
>
}
6500
return nil
6501
}