8 types derived from RateLimitLease
Microsoft.AspNetCore.RateLimiting (1)
DefaultCombinedLease.cs (1)
8internal sealed class DefaultCombinedLease : RateLimitLease
Microsoft.AspNetCore.RateLimiting.Tests (1)
TestRateLimitLease.cs (1)
8internal class TestRateLimitLease : RateLimitLease
System.Threading.RateLimiting (6)
System\Threading\RateLimiting\CombinedRateLimitLease.cs (1)
9internal sealed class CombinedRateLimitLease : RateLimitLease
System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)
362private sealed class ConcurrencyLease : RateLimitLease
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)
419private sealed class FixedWindowLease : RateLimitLease
System\Threading\RateLimiting\NoopLimiter.cs (1)
42private sealed class NoopLease : RateLimitLease
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)
432private sealed class SlidingWindowLease : RateLimitLease
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
433private sealed class TokenBucketLease : RateLimitLease
126 references to RateLimitLease
Microsoft.AspNetCore.ConcurrencyLimiter (6)
QueuePolicies\BasePolicy.cs (6)
15private readonly ConcurrentQueue<RateLimitLease> _leases = new ConcurrentQueue<RateLimitLease>(); 48var lease = _limiter.AttemptAcquire(); 73if (!_leases.TryDequeue(out var lease)) 86private async ValueTask<bool> Awaited(ValueTask<RateLimitLease> task) 88var lease = await task;
Microsoft.AspNetCore.RateLimiting (10)
DefaultCombinedLease.cs (4)
10private readonly RateLimitLease _globalLease; 11private readonly RateLimitLease _endpointLease; 14public DefaultCombinedLease(RateLimitLease globalLease, RateLimitLease endpointLease)
LeaseContext.cs (1)
12public RateLimitLease? Lease { get; init; }
OnRejectedContext.cs (1)
20/// Gets or sets the failed <see cref="RateLimitLease"/> that the OnRejected callback will have access to
RateLimitingMiddleware.cs (4)
181RateLimitLease? globalLease = null; 182RateLimitLease? endpointLease = null; 212RateLimitLease? globalLease = null; 213RateLimitLease? endpointLease = null;
Microsoft.AspNetCore.RateLimiting.Tests (14)
TestPartitionedRateLimiter.cs (8)
34protected override RateLimitLease AttemptAcquireCore(TResource resourceID, int permitCount) 40var leases = new List<RateLimitLease>(); 43var lease = limiter.AttemptAcquire(); 50foreach (var unusedLease in leases) 60protected override async ValueTask<RateLimitLease> AcquireAsyncCore(TResource resourceID, int permitCount, CancellationToken cancellationToken) 66var leases = new List<RateLimitLease>(); 71foreach (var lease in leases) 75foreach (var unusedLease in leases)
TestRateLimiter.cs (3)
24protected override RateLimitLease AttemptAcquireCore(int permitCount) 29protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken) 32return new ValueTask<RateLimitLease>(new TestRateLimitLease(_alwaysAccept, null));
TestRateLimitLease.cs (3)
10internal List<RateLimitLease> _leases; 12public TestRateLimitLease(bool isAcquired, List<RateLimitLease> leases) 31foreach (var lease in _leases)
System.Threading.RateLimiting (96)
System\Threading\RateLimiting\ChainedPartitionedRateLimiter.cs (8)
59protected override RateLimitLease AttemptAcquireCore(TResource resource, int permitCount) 63RateLimitLease[]? leases = null; 67RateLimitLease? lease = null; 79RateLimitLease? notAcquiredLease = ChainedRateLimiter.CommonAcquireLogic(exception, lease, ref leases, i, _limiters.Length); 90protected override async ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken) 94RateLimitLease[]? leases = null; 98RateLimitLease? lease = null; 110RateLimitLease? notAcquiredLease = ChainedRateLimiter.CommonAcquireLogic(exception, lease, ref leases, i, _limiters.Length);
System\Threading\RateLimiting\ChainedRateLimiter.cs (13)
80protected override RateLimitLease AttemptAcquireCore(int permitCount) 84RateLimitLease[]? leases = null; 88RateLimitLease? lease = null; 100RateLimitLease? notAcquiredLease = CommonAcquireLogic(exception, lease, ref leases, i, _limiters.Length); 111protected override async ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken) 115RateLimitLease[]? leases = null; 119RateLimitLease? lease = null; 131RateLimitLease? notAcquiredLease = CommonAcquireLogic(exception, lease, ref leases, i, _limiters.Length); 155internal static RateLimitLease? CommonAcquireLogic(Exception? ex, RateLimitLease? lease, ref RateLimitLease[]? leases, int index, int length) 178leases ??= new RateLimitLease[length]; 183private static AggregateException? CommonDispose(RateLimitLease[]? leases, int i)
System\Threading\RateLimiting\CombinedRateLimitLease.cs (4)
11private RateLimitLease[]? _leases; 14public CombinedRateLimitLease(RateLimitLease[] leases) 33foreach (RateLimitLease lease in _leases) 50foreach (RateLimitLease lease in _leases)
System\Threading\RateLimiting\ConcurrencyLimiter.cs (10)
76protected override RateLimitLease AttemptAcquireCore(int permitCount) 103if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 115protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default) 127return new ValueTask<RateLimitLease>(SuccessfulLease); 135if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 137return new ValueTask<RateLimitLease>(lease); 178return new ValueTask<RateLimitLease>(QueueLimitLease); 187return new ValueTask<RateLimitLease>(request.Task); 191private bool TryLeaseUnsynchronized(int permitCount, [NotNullWhen(true)] out RateLimitLease? lease) 410private sealed class RequestRegistration : TaskCompletionSource<RateLimitLease>
System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (2)
77protected override RateLimitLease AttemptAcquireCore(TResource resource, int permitCount) 82protected override ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken)
System\Threading\RateLimiting\FixedWindowRateLimiter.cs (12)
31private static readonly RateLimitLease SuccessfulLease = new FixedWindowLease(true, null); 32private static readonly RateLimitLease FailedLease = new FixedWindowLease(false, null); 96protected override RateLimitLease AttemptAcquireCore(int permitCount) 122if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 133protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default) 147return new ValueTask<RateLimitLease>(SuccessfulLease); 153if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 155return new ValueTask<RateLimitLease>(lease); 196return new ValueTask<RateLimitLease>(CreateFailedWindowLease(permitCount)); 205return new ValueTask<RateLimitLease>(registration.Task); 218private bool TryLeaseUnsynchronized(int permitCount, [NotNullWhen(true)] out RateLimitLease? lease) 448private sealed class RequestRegistration : TaskCompletionSource<RateLimitLease>
System\Threading\RateLimiting\MetadataName.T.cs (1)
9/// A strongly-typed name of metadata that can be stored in a <see cref="RateLimitLease"/>.
System\Threading\RateLimiting\NoopLimiter.cs (4)
11private static readonly RateLimitLease _lease = new NoopLease(); 30protected override RateLimitLease AttemptAcquireCore(int permitCount) 36protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken) 39return new ValueTask<RateLimitLease>(_lease);
System\Threading\RateLimiting\PartitionedRateLimiter.cs (1)
46/// <see cref="RateLimitLease"/>s returned will aggregate metadata and for duplicates use the value of the first lease with the same metadata name.
System\Threading\RateLimiting\PartitionedRateLimiter.T.cs (6)
30public RateLimitLease AttemptAcquire(TResource resource, int permitCount = 1) 46protected abstract RateLimitLease AttemptAcquireCore(TResource resource, int permitCount); 59public ValueTask<RateLimitLease> AcquireAsync(TResource resource, int permitCount = 1, CancellationToken cancellationToken = default) 68return new ValueTask<RateLimitLease>(Task.FromCanceled<RateLimitLease>(cancellationToken)); 81protected abstract ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken);
System\Threading\RateLimiting\RateLimiter.cs (7)
26/// <see cref="RateLimitLease"/>s returned will aggregate metadata and for duplicates use the value of the first lease with the same metadata name. 69public RateLimitLease AttemptAcquire(int permitCount = 1) 84protected abstract RateLimitLease AttemptAcquireCore(int permitCount); 96public ValueTask<RateLimitLease> AcquireAsync(int permitCount = 1, CancellationToken cancellationToken = default) 105return new ValueTask<RateLimitLease>(Task.FromCanceled<RateLimitLease>(cancellationToken)); 117protected abstract ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken);
System\Threading\RateLimiting\RateLimiterStatistics.cs (2)
27/// Gets the total number of failed <see cref="RateLimitLease"/>s returned. 32/// Gets the total number of successful <see cref="RateLimitLease"/>s returned.
System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (12)
35private static readonly RateLimitLease SuccessfulLease = new SlidingWindowLease(true, null); 36private static readonly RateLimitLease FailedLease = new SlidingWindowLease(false, null); 110protected override RateLimitLease AttemptAcquireCore(int permitCount) 133if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 145protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default) 159return new ValueTask<RateLimitLease>(SuccessfulLease); 165if (TryLeaseUnsynchronized(permitCount, out RateLimitLease? lease)) 167return new ValueTask<RateLimitLease>(lease); 208return new ValueTask<RateLimitLease>(FailedLease); 217return new ValueTask<RateLimitLease>(registration.Task); 221private bool TryLeaseUnsynchronized(int permitCount, [NotNullWhen(true)] out RateLimitLease? lease) 461private sealed class RequestRegistration : TaskCompletionSource<RateLimitLease>
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (12)
33private static readonly RateLimitLease SuccessfulLease = new TokenBucketLease(true, null); 34private static readonly RateLimitLease FailedLease = new TokenBucketLease(false, null); 104protected override RateLimitLease AttemptAcquireCore(int tokenCount) 127if (TryLeaseUnsynchronized(tokenCount, out RateLimitLease? lease)) 138protected override ValueTask<RateLimitLease> AcquireAsyncCore(int tokenCount, CancellationToken cancellationToken = default) 152return new ValueTask<RateLimitLease>(SuccessfulLease); 158if (TryLeaseUnsynchronized(tokenCount, out RateLimitLease? lease)) 160return new ValueTask<RateLimitLease>(lease); 201return new ValueTask<RateLimitLease>(CreateFailedTokenLease(tokenCount)); 210return new ValueTask<RateLimitLease>(registration.Task); 225private bool TryLeaseUnsynchronized(int tokenCount, [NotNullWhen(true)] out RateLimitLease? lease) 462private sealed class RequestRegistration : TaskCompletionSource<RateLimitLease>
System\Threading\RateLimiting\TranslatingLimiter.cs (2)
30protected override RateLimitLease AttemptAcquireCore(TResource resource, int permitCount) 37protected override ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken)