2 instantiations of CallbackThrottler
Aspire.Dashboard (2)
Model\ResourceOutgoingPeerResolver.cs (1)
377
_callbackThrottler = new
CallbackThrottler
(
Otlp\Storage\Subscription.cs (1)
32
_callbackThrottler = new
CallbackThrottler
(name, logger, minExecuteInterval, callback, executionContext);
7 references to CallbackThrottler
Aspire.Dashboard (4)
Model\ResourceOutgoingPeerResolver.cs (2)
368
private readonly
CallbackThrottler
_callbackThrottler;
380
CallbackThrottler
.DefaultMinExecuteInterval,
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
22
private TimeSpan _subscriptionMinExecuteInterval =
CallbackThrottler
.DefaultMinExecuteInterval;
Otlp\Storage\Subscription.cs (1)
17
private readonly
CallbackThrottler
_callbackThrottler;
Aspire.Dashboard.Tests (3)
ResourceOutgoingPeerResolverTests.cs (2)
282
Assert.Equal(TimeSpan.FromMilliseconds(500),
CallbackThrottler
.DefaultMinExecuteInterval);
350
Assert.True(elapsed >=
CallbackThrottler
.DefaultMinExecuteInterval - TimeSpan.FromMilliseconds(50), $"Callbacks executed too quickly: {elapsed}.");
TelemetryRepositoryTests\LogTests.cs (1)
959
var minExecuteInterval =
CallbackThrottler
.DefaultMinExecuteInterval;