/
aprogrammer
/
reverse-proxy-ms-yarp
Обзор
Документация
Войти
/
aprogrammer
/
reverse-proxy-ms-yarp
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
src/Kubernetes.Controller/Queues/ProcessingRateLimitedQueue.cs
24 строки
661 B
David Bevin
Tidied up namespaces for Kubernetes projects (#1717)
27 май 2022, 18:52
Не верифицирован
27 май 2022, 18:52
2fa9c3b
Код
Авторство
О чём код?
// Copyright (c) Microsoft Corporation. // Licensed under the MIT License. using System.Threading; using System.Threading.Tasks; using Yarp.Kubernetes.Controller.Rate; namespace Yarp.Kubernetes.Controller.Queues; public class ProcessingRateLimitedQueue<TItem> : WorkQueue<TItem> { private readonly Limiter _limiter; public ProcessingRateLimitedQueue(double perSecond, int burst) { _limiter = new Limiter(new Limit(perSecond), burst); } protected override async Task OnGetAsync(CancellationToken cancellationToken) { var delay = _limiter.Reserve().Delay(); await Task.Delay(delay, cancellationToken); } }