Mostlylucid.Ephemeral.Patterns.AdaptiveRate
1.7.1
dotnet add package Mostlylucid.Ephemeral.Patterns.AdaptiveRate --version 1.7.1
NuGet\Install-Package Mostlylucid.Ephemeral.Patterns.AdaptiveRate -Version 1.7.1
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="Mostlylucid.Ephemeral.Patterns.AdaptiveRate" Version="1.7.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Mostlylucid.Ephemeral.Patterns.AdaptiveRate" Version="1.7.1" />
<PackageReference Include="Mostlylucid.Ephemeral.Patterns.AdaptiveRate" />
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add Mostlylucid.Ephemeral.Patterns.AdaptiveRate --version 1.7.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: Mostlylucid.Ephemeral.Patterns.AdaptiveRate, 1.7.1"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
#:package Mostlylucid.Ephemeral.Patterns.AdaptiveRate@1.7.1
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=Mostlylucid.Ephemeral.Patterns.AdaptiveRate&version=1.7.1
#tool nuget:?package=Mostlylucid.Ephemeral.Patterns.AdaptiveRate&version=1.7.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
Mostlylucid.Ephemeral.Patterns.AdaptiveRate
🚨🚨 WARNING 🚨🚨 - Though in the 1.x range of version THINGS WILL STILL BREAK. This is the lab for developing this concept when stabilized it'll becoe the first styloflow release 🚨🚨🚨
Adaptive rate limiting using ephemeral signals for automatic backoff.
dotnet add package mostlylucid.ephemeral.patterns.adaptiverate
Quick Start
using Mostlylucid.Ephemeral.Patterns.AdaptiveRate;
await using var service = new AdaptiveRateService<ApiRequest>(
async (req, ct) => await CallApiAsync(req, ct),
maxConcurrency: 8);
// Automatically backs off when rate-limit signals present
await service.ProcessAsync(request);
All Options
new AdaptiveRateService<T>(
// Required: async work processor
processAsync: async (item, ct) => await ProcessAsync(item, ct),
// Max concurrent operations
// Default: 8
maxConcurrency: 8
)
API Reference
// Process item with automatic rate limit handling
await service.ProcessAsync(item);
// Check queue status
int pending = service.PendingCount;
int active = service.ActiveCount;
// Dispose
await service.DisposeAsync();
Signal Format
rate-limit- Generic rate limit, defer for default intervalrate-limit:5000ms- Rate limit with specific retry-after in milliseconds
How It Works
When a rate-limit or rate-limit:XXXms signal is present, new work is automatically deferred. No explicit
coordination needed between operations.
[Request] -> Check signals -> [rate-limit:1000ms] -> Wait 1s -> Process
[Request] -> Check signals -> [no signals] -> Process immediately
Example: API with Rate Limiting
await using var service = new AdaptiveRateService<ApiRequest>(
async (req, ct) =>
{
var response = await httpClient.SendAsync(req.Message, ct);
if (response.StatusCode == HttpStatusCode.TooManyRequests)
{
var retryAfter = response.Headers.RetryAfter?.Delta ?? TimeSpan.FromSeconds(5);
// Signal will auto-defer subsequent requests
throw new RateLimitException("Rate limited", retryAfter);
}
response.EnsureSuccessStatusCode();
},
maxConcurrency: 4);
foreach (var request in requests)
await service.ProcessAsync(request);
Related Packages
| Package | Description |
|---|---|
| mostlylucid.ephemeral | Core library |
| mostlylucid.ephemeral.patterns.backpressure | Backpressure pattern |
| mostlylucid.ephemeral.complete | All in one DLL |
License
Unlicense (public domain)
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 is compatible. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net10.0
- mostlylucid.ephemeral (>= 1.7.1)
-
net6.0
- mostlylucid.ephemeral (>= 1.7.1)
-
net7.0
- mostlylucid.ephemeral (>= 1.7.1)
-
net8.0
- mostlylucid.ephemeral (>= 1.7.1)
-
net9.0
- mostlylucid.ephemeral (>= 1.7.1)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.