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)
730await eventing.PublishAsync<ResourceStoppedEvent>(new(portResource, e.Services, new(portResource, portResource.Name, stoppedSnapshot!)), ct).ConfigureAwait(false);
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
301var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
140 references to ResourceEvent
Aspire.Hosting (51)
ApplicationModel\ResourceCommandService.cs (1)
47if (!_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)
104await foreach (var resourceEvent in resourceEvents.WithCancellation(linkedToken).ConfigureAwait(false))
Backchannel\AuxiliaryBackchannelRpcTarget.cs (6)
274var resourceEvent = await notificationService.WaitForResourceHealthyAsync(resourceName, WaitBehavior.StopOnResourceUnavailable, cancellationToken).ConfigureAwait(false); 286var resourceEvent = await notificationService.WaitForResourceAsync( 305var resourceEvent = await notificationService.WaitForResourceAsync( 463if (notificationService.TryGetCurrentState(resourceName, out var resourceEvent)) 485await foreach (var resourceEvent in resourceEvents.WithCancellation(cancellationToken).ConfigureAwait(false)) 502ResourceEvent resourceEvent,
Dashboard\DashboardEventHandlers.cs (1)
760await 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)
614app.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)
79var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
DistributedApplicationTests.cs (15)
144var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 190var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 191var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 212var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 220var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 327var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 399var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 400var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 420var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 427var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 477ResourceEvent? notStartedResourceEvent = null; 478ResourceEvent? dependentResourceEvent = null; 505var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 512var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 961var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
301var testResourceEvent = new ResourceEvent(resource.Resource, "test-resource", testSnapshot);
ExternalServiceTests.cs (3)
320var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 347var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync( 374var resourceEvent = await app.ResourceNotifications.WaitForResourceAsync(
Health\ResourceHealthCheckServiceTests.cs (12)
37var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 45var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 77var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 85var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 120var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 128var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", 586var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 595var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 602var healthyEvent = await app.ResourceNotifications.WaitForResourceHealthyAsync("resource").DefaultTimeout(); 632var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 640var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 648var unhealthyEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.HealthStatus == HealthStatus.Unhealthy).DefaultTimeout();
Orchestrator\ApplicationOrchestratorTests.cs (15)
49await foreach (var item in resourceNotificationService.WatchAsync()) 97await foreach (var item in resourceNotificationService.WatchAsync()) 197await foreach (var item in resourceNotificationService.WatchAsync()) 263await foreach (var item in resourceNotificationService.WatchAsync()) 315await foreach (var item in resourceNotificationService.WatchAsync()) 432await foreach (var item in resourceNotificationService.WatchAsync()) 630var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 631var childContainerState = resourceNotificationService.TryGetCurrentState(childContainer.Resource.Name, out var childContainerEvent) ? childContainerEvent.Snapshot.State?.Text : null; 632var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 677var parentState = resourceNotificationService.TryGetCurrentState("parent-container-dcp", out var parentEvent) ? parentEvent.Snapshot.State?.Text : null; 678var childProjectState = resourceNotificationService.TryGetCurrentState(childProject.Resource.Name, out var childProjectEvent) ? childProjectEvent.Snapshot.State?.Text : null; 679var customChildState = resourceNotificationService.TryGetCurrentState(customChild.Resource.Name, out var customChildEvent) ? customChildEvent.Snapshot.State?.Text : null; 718await foreach (var item in resourceNotificationService.WatchAsync()) 775await foreach (var item in resourceNotificationService.WatchAsync()) 829await foreach (var item in resourceNotificationService.WatchAsync())
Orchestrator\ParameterProcessorTests.cs (1)
86await foreach (var resourceEvent in notificationService.WatchAsync().ConfigureAwait(false))
ResourceNotificationTests.cs (21)
72await foreach (var item in notificationService.WatchAsync(cts.Token)) 81var resourceEvent = await watchTask.DefaultTimeout(); 94async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 96var values = new List<ResourceEvent>(); 98await foreach (var item in notificationService.WatchAsync(cancellationToken)) 147async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellation) 149var values = new List<ResourceEvent>(); 151await foreach (var item in notificationService.WatchAsync(cancellation)) 489async Task<List<ResourceEvent>> GetValuesAsync(CancellationToken cancellationToken) 491var values = new List<ResourceEvent>(); 493await foreach (var item in notificationService.WatchAsync(cancellationToken)) 527var firstEvent = values[0]; 532var secondEvent = values[1]; 549async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 551await foreach (var item in notificationService.WatchAsync(cancellationToken)) 567var value = await enumerableTask.DefaultTimeout(); 585async Task<ResourceEvent> GetFirstValueAsync(CancellationToken cancellationToken) 587await foreach (var item in notificationService.WatchAsync(cancellationToken)) 603var value = await enumerableTask.DefaultTimeout(); 642var resourceEvent = await waitTask.DefaultTimeout(); 711var resourceEvent = await waitTask.DefaultTimeout();
Utils\LoggerNotificationExtensions.cs (1)
132await foreach (var resourceEvent in app.ResourceNotifications.WatchAsync(cancellationTokenSource.Token).ConfigureAwait(false))
WithHttpCommandTests.cs (4)
423var startingEvent = await app.ResourceNotifications.WaitForResourceAsync( 436var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 479var runningEvent = await app.ResourceNotifications.WaitForResourceAsync( 494var enabledEvent = await app.ResourceNotifications.WaitForResourceAsync(
WithUrlsTests.cs (7)
385var resourceEvent = await rns.WaitForResourceAsync( 412var resourceEvent = await rns.WaitForResourceAsync( 445var resourceEvent = await rns.WaitForResourceAsync( 479await foreach (var notification in rns.WatchAsync(cts.Token)) 597await foreach (var notification in rns.WatchAsync(cts.Token)) 675var resourceEvent = await rns.WaitForResourceAsync( 977var 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))