4 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
460
resourceEvent = new
ResourceEvent
(state.Resource, resourceId, snapshot);
483
resourceEvent = new
ResourceEvent
(m.Value.Resource, m.Key, m.Value.LastSnapshot);
521
yield return new
ResourceEvent
(state.Value.Resource, resourceId, snapshot);
579
OnResourceUpdated?.Invoke(new
ResourceEvent
(resource, resourceId, newState));
91 references to ResourceEvent
Aspire.Hosting (36)
ApplicationModel\ResourceCommandService.cs (1)
47
if (!_resourceNotificationService.TryGetCurrentState(resourceId, out
var
resourceEvent))
ApplicationModel\ResourceNotificationService.cs (20)
30
private Action<
ResourceEvent
>? OnResourceUpdated { get; set; }
129
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
162
var
resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
242
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default)
275
public async Task<
ResourceEvent
> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default)
278
var
resourceEvent = await WaitForResourceCoreAsync(resourceName, re => ShouldYield(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
324
var
resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false);
403
/// <param name="predicate">A predicate which is evaluated for each <see cref="
ResourceEvent
"/> for the selected resource.</param>
408
public async Task<
ResourceEvent
> WaitForResourceAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
411
var
resourceEvent = await WaitForResourceCoreAsync(resourceName, predicate, cancellationToken).ConfigureAwait(false);
417
private async Task<
ResourceEvent
> WaitForResourceCoreAsync(string resourceName, Func<
ResourceEvent
, bool> predicate, CancellationToken cancellationToken = default)
421
await foreach (
var
resourceEvent in WatchAsync(watchToken).ConfigureAwait(false))
451
/// <param name="resourceEvent">When this method returns, contains the <see cref="
ResourceEvent
"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param>
453
public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out
ResourceEvent
? resourceEvent)
495
public async IAsyncEnumerable<
ResourceEvent
> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default)
497
var channel = Channel.CreateUnbounded<
ResourceEvent
>();
499
void WriteToChannel(
ResourceEvent
resourceEvent) =>
527
await foreach (
var
item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false))
Backchannel\AppHostRpcTarget.cs (1)
73
await foreach (
var
resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardLifecycleHook.cs (1)
369
await foreach (
var
notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
66
await foreach (
var
@event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
28
await foreach (
var
resourceEvent in resourceEvents.ConfigureAwait(false))
Exec\ExecResourceManager.cs (1)
127
if (!_resourceNotificationService.TryGetCurrentState(dcpExecResourceName, out
var
resourceEvent))
Health\ResourceHealthCheckService.cs (8)
29
await foreach (
var
resourceEvent in resourceEvents.ConfigureAwait(false))
128
ResourceEvent
? currentEvent = null;
311
public ResourceMonitorState(ILogger logger,
ResourceEvent
initialEvent, CancellationToken serviceStoppingToken)
324
public
ResourceEvent
LatestEvent { get; private set; }
332
public void SetLatestEvent(
ResourceEvent
resourceEvent)
348
internal async Task<bool> DelayAsync(
ResourceEvent
? currentEvent, TimeSpan delay, CancellationToken cancellationToken)
371
private static bool ShouldInterrupt(
ResourceEvent
currentEvent,
ResourceEvent
previousEvent)
ResourceBuilderExtensions.cs (1)
1792
await foreach (
var
resourceEvent in rns.WatchAsync(ct).WithCancellation(ct))
ResourceLoggerForwarderService.cs (1)
42
await foreach (
var
resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
64
await foreach (
var
resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
40
var
state = await rns.WaitForResourceAsync(
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
597
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
578
var
resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (49)
Codespaces\CodespacesUrlRewriterTests.cs (1)
80
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (13)
133
var
resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
177
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
178
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
199
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
207
var
dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
252
var
notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
253
var
dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
273
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
280
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
328
ResourceEvent
? notStartedResourceEvent = null;
329
ResourceEvent
? dependentResourceEvent = null;
356
var
runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
363
var
dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);
ExternalServiceTests.cs (3)
308
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
335
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
362
var
resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
37
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
45
var
healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
77
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
85
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
120
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
128
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource",
586
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
595
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
602
var
healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout();
632
var
startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout();
640
var
runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
648
var
unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (6)
39
await foreach (
var
item in resourceNotificationService.WatchAsync())
86
await foreach (
var
item in resourceNotificationService.WatchAsync())
184
await foreach (
var
item in resourceNotificationService.WatchAsync())
249
await foreach (
var
item in resourceNotificationService.WatchAsync())
300
await foreach (
var
item in resourceNotificationService.WatchAsync())
415
await foreach (
var
item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
76
await foreach (
var
resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceNotificationTests.cs (6)
50
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellationToken)
52
var values = new List<
ResourceEvent
>();
54
await foreach (
var
item in notificationService.WatchAsync(cancellationToken))
103
async Task<List<
ResourceEvent
>> GetValuesAsync(CancellationToken cancellation)
105
var values = new List<
ResourceEvent
>();
107
await foreach (
var
item in notificationService.WatchAsync(cancellation))
Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (2)
384
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
454
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(watchCts.Token).WithCancellation(watchCts.Token))
WithUrlsTests.cs (4)
331
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
367
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
454
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
575
await foreach (
var
notification in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132
await foreach (
var
resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))