6 instantiations of ResourceEvent
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (4)
521resourceEvent = new ResourceEvent(state.Resource, resourceId, snapshot); 544resourceEvent = new ResourceEvent(m.Value.Resource, m.Key, m.Value.LastSnapshot); 582yield return new ResourceEvent(state.Value.Resource, resourceId, snapshot); 650OnResourceUpdated?.Invoke(new ResourceEvent(resource, resourceId, newState));
Aspire.Hosting.DevTunnels (1)
DevTunnelResourceBuilderExtensions.cs (1)
768await eventing.PublishAsync<ResourceStoppedEvent>(new(portResource, e.Services, new(portResource, portResource.Name, stoppedSnapshot!)), ct).ConfigureAwait(false);
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
302var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
140 references to ResourceEvent
Aspire.Hosting (51)
ApplicationModel\ResourceCommandService.cs (1)
57if (!_resourceNotificationService.TryGetCurrentState(resourceId, out var resourceEvent))
ApplicationModel\ResourceNotificationService.cs (22)
31private Action<ResourceEvent>? OnResourceUpdated { get; set; } 128var resourceEvent = await WaitForResourceCoreAsync( 189public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, CancellationToken cancellationToken = default) 222public async Task<ResourceEvent> WaitForResourceHealthyAsync(string resourceName, WaitBehavior waitBehavior, CancellationToken cancellationToken = default) 225var resourceEvent = await WaitForResourceCoreAsync( 286var resourceEvent = await WaitForResourceCoreAsync( 326Func<ILogger, string, string, ResourceEvent, Task> postRunningAction, CancellationToken cancellationToken) 345var resourceEvent = await WaitForResourceCoreAsync( 452/// <param name="predicate">A predicate which is evaluated for each <see cref="ResourceEvent"/> for the selected resource.</param> 457public async Task<ResourceEvent> WaitForResourceAsync(string resourceName, Func<ResourceEvent, bool> predicate, CancellationToken cancellationToken = default) 460var resourceEvent = await WaitForResourceCoreAsync( 470private async Task<ResourceEvent> WaitForResourceCoreAsync(string resourceName, Func<ResourceEvent, bool> predicate, string cancellationMessage, CancellationToken cancellationToken = default) 476await foreach (var resourceEvent in WatchAsync(watchToken).ConfigureAwait(false)) 512/// <param name="resourceEvent">When this method returns, contains the <see cref="ResourceEvent"/> for the specified resource id, if found; otherwise, <see langword="null"/>.</param> 514public bool TryGetCurrentState(string resourceId, [NotNullWhen(true)] out ResourceEvent? resourceEvent) 556public async IAsyncEnumerable<ResourceEvent> WatchAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 558var channel = Channel.CreateUnbounded<ResourceEvent>(); 560void WriteToChannel(ResourceEvent resourceEvent) => 588await foreach (var item in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 884if (TryGetCurrentState(resourceName, out var evt) && evt.Snapshot != null)
ApplicationModel\ResourceStoppedEvent.cs (2)
17public class ResourceStoppedEvent(IResource resource, IServiceProvider services, ResourceEvent resourceEvent) : IDistributedApplicationResourceEvent 28public ResourceEvent ResourceEvent { get; } = resourceEvent;
Ats\NotificationExports.cs (3)
45var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName).ConfigureAwait(false); 68if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 135internal static ResourceEventDto FromResourceEvent(ResourceEvent resourceEvent)
Backchannel\AppHostRpcTarget.cs (1)
98await foreach (var resourceEvent in resourceEvents.WithCancellation(linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (6)
275var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName, WaitBehavior.StopOnResourceUnavailable, cancellationToken).ConfigureAwait(false); 287var resourceEvent = await notificationService.WaitForResourceAsync( 306var resourceEvent = await notificationService.WaitForResourceAsync( 464if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 486await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false)) 503ResourceEvent resourceEvent,
Dashboard\DashboardEventHandlers.cs (1)
797await foreach (var notification in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Dashboard\DashboardServiceData.cs (1)
68await foreach (var @event in resourceNotificationService.WatchAsync().WithCancellation(cancellationToken).ConfigureAwait(false))
Devcontainers\Codespaces\CodespacesResourceUrlRewriterService.cs (1)
28await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false))
DistributedApplication.cs (1)
616app.ResourceNotifications.TryGetCurrentState(instanceName, out var resourceEvent);
Exec\ExecResourceManager.cs (1)
127if (!_resourceNotificationService.TryGetCurrentState(dcpExecResourceName, out var resourceEvent))
Health\ResourceHealthCheckService.cs (8)
29await foreach (var resourceEvent in resourceEvents.ConfigureAwait(false)) 128ResourceEvent? currentEvent = null; 317public ResourceMonitorState(ILogger logger, ResourceEvent initialEvent, CancellationToken serviceStoppingToken) 330public ResourceEvent LatestEvent { get; private set; } 338public void SetLatestEvent(ResourceEvent resourceEvent) 354internal async Task<bool> DelayAsync(ResourceEvent? currentEvent, TimeSpan delay, CancellationToken cancellationToken) 377private static bool ShouldInterrupt(ResourceEvent currentEvent, ResourceEvent previousEvent)
Orchestrator\ApplicationOrchestrator.cs (2)
495if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var previousResourceEvent)) 516if (_notificationService.TryGetCurrentState(context.DcpResourceName, out var currentResourceEvent))
ResourceLoggerForwarderService.cs (1)
42await foreach (var resourceEvent in resourceNotificationService.WatchAsync(cancellationToken).ConfigureAwait(false))
Aspire.Hosting.Azure.Tests (1)
AzureBicepProvisionerTests.cs (1)
69await foreach (var resourceEvent in rns.WatchAsync(cts.Token).WithCancellation(cts.Token))
Aspire.Hosting.Containers.Tests (1)
DockerSocketBindMountTests.cs (1)
40var state = await rns.WaitForResourceAsync(
Aspire.Hosting.DotnetTool.Tests (2)
DotnetToolFunctionalTests.cs.cs (2)
28Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState)); 50Assert.True(app.ResourceNotifications.TryGetCurrentState(resource.Resource.Name, out var resourceState));
Aspire.Hosting.MySql.Tests (1)
MySqlFunctionalTests.cs (1)
603var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.PostgreSQL.Tests (1)
PostgresFunctionalTests.cs (1)
580var resourceEvent = await rns.WaitForResourceAsync(resourceName, (evt) =>
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
Aspire.Hosting.Tests (81)
Codespaces\CodespacesUrlRewriterTests.cs (1)
80var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (15)
145var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 191var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 192var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 328var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 400var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 401var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 421var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 428var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 478ResourceEvent? notStartedResourceEvent = null; 479ResourceEvent? dependentResourceEvent = null; 506var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 513var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 962var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
302var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
ExternalServiceTests.cs (3)
321var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 348var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 375var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 46var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 129var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 603var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 649var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (15)
50await foreach (var item in resourceNotificationService.WatchAsync()) 98await foreach (var item in resourceNotificationService.WatchAsync()) 198await foreach (var item in resourceNotificationService.WatchAsync()) 264await foreach (var item in resourceNotificationService.WatchAsync()) 316await foreach (var item in resourceNotificationService.WatchAsync()) 433await foreach (var item in resourceNotificationService.WatchAsync()) 631var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 632var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null; 633var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 678var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 679var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null; 680var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 719await foreach (var item in resourceNotificationService.WatchAsync()) 776await foreach (var item in resourceNotificationService.WatchAsync()) 830await foreach (var item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
87await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceNotificationTests.cs (21)
73await foreach (var item in notificationService.WatchAsync(cts.Token)) 82var resourceEvent = await watchTask.DefaultTimeout(); 95async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 97var values = new List<ResourceEvent>(); 99await foreach (var item in notificationService.WatchAsync(cancellationToken)) 148async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 150var values = new List<ResourceEvent>(); 152await foreach (var item in notificationService.WatchAsync(cancellation)) 490async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 492var values = new List<ResourceEvent>(); 494await foreach (var item in notificationService.WatchAsync(cancellationToken)) 528var firstEvent = values[0]; 533var secondEvent = values[1]; 550async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 552await foreach (var item in notificationService.WatchAsync(cancellationToken)) 568var value = await enumerableTask.DefaultTimeout(); 586async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 588await foreach (var item in notificationService.WatchAsync(cancellationToken)) 604var value = await enumerableTask.DefaultTimeout(); 643var resourceEvent = await waitTask.DefaultTimeout(); 712var resourceEvent = await waitTask.DefaultTimeout();
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (4)
424var startingEvent = await app.ResourceNotifications.WaitForResourceAsync( 437var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 480var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 495var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync(
WithUrlsTests.cs (7)
386var resourceEvent = await rns.WaitForResourceAsync( 413var resourceEvent = await rns.WaitForResourceAsync( 446var resourceEvent = await rns.WaitForResourceAsync( 480await foreach (var notification in rns.WatchAsync(cts.Token)) 598await foreach (var notification in rns.WatchAsync(cts.Token)) 676var resourceEvent = await rns.WaitForResourceAsync( 978var resourceEvent = await rns.WaitForResourceAsync(
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))