43 references to ResourceEvent
Aspire.Hosting (22)
ApplicationModel\ResourceNotificationService.cs (14)
27
private Action<
ResourceEvent
>? OnResourceUpdated { get; set; }
117
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
210
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default)
320
/// <param name="predicate">A predicate which is evaluated for each <see cref="
ResourceEvent
"/> for the selected resource.</param>
325
public async Task<
ResourceEvent
> WaitForResourceAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
328
var
resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false);
334
private async Task<
ResourceEvent
> WaitForResourceCoreAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
338
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
357
public async IAsyncEnumerable<
ResourceEvent
> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
359
var channel = Channel.CreateUnbounded<
ResourceEvent
>();
361
void WriteToChannel(
ResourceEvent
resourceEvent) =>
389
await foreach (
var
item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
59
await foreach (
var
@event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Health\ResourceHealthCheckService.cs (7)
112
ResourceEvent
? currentEvent = null;
283
public ResourceMonitorState(ILogger logger,
ResourceEvent
initialEvent, CancellationToken serviceStoppingToken)
296
public
ResourceEvent
LatestEvent { get; private set; }
304
public void SetLatestEvent(
ResourceEvent
resourceEvent)
320
internal async Task<bool> DelayAsync(
ResourceEvent
? currentEvent, TimeSpan delay, CancellationToken cancellationToken)
347
private static bool ShouldInterrupt(
ResourceEvent
currentEvent,
ResourceEvent
previousEvent)
Aspire.Hosting.Redis.Tests (1)
RedisFunctionalTests.cs (1)
225
var
latestEvent = await rns.WaitForResourceHealthyAsync(redisInsightBuilder.Resource.Name, cts.Token);
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
123
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (18)
DistributedApplicationTests.cs (3)
131
var
resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
175
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
176
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Health\ResourceHealthCheckServiceTests.cs (4)
40
var
startingEvent = await rns.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
48
var
healthyEvent = await rns.WaitForResourceHealthyAsync("resource").DefaultTimeout();
81
var
startingEvent = await rns.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
89
var
runningEvent = await rns.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (4)
40
await foreach (
var
item in resourceNotificationService.WatchAsync())
91
await foreach (
var
item in resourceNotificationService.WatchAsync())
155
await foreach (
var
item in resourceNotificationService.WatchAsync())
207
await foreach (
var
item in resourceNotificationService.WatchAsync())
ResourceNotificationTests.cs (6)
51
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellationToken)
53
var values = new List<
ResourceEvent
>();
55
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
104
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellation)
106
var values = new List<
ResourceEvent
>();
108
await foreach (
var
item in notificationService.WatchAsync(cancellation))
Utils\LoggerNotificationExtensions.cs (1)
123
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
123
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))