10 instantiations of CustomResourceSnapshot
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (1)
703previousState ??= new CustomResourceSnapshot()
ConnectionStringBuilderExtensions.cs (1)
45.WithInitialState(new CustomResourceSnapshot
Dashboard\DashboardLifecycleHook.cs (1)
158var snapshot = new CustomResourceSnapshot()
ParameterResourceBuilderExtensions.cs (1)
161var state = new CustomResourceSnapshot()
Aspire.Hosting.Tests (2)
Dashboard\ResourcePublisherTests.cs (1)
185return new GenericResourceSnapshot(new()
ResourceCommandAnnotationTests.cs (1)
52ResourceSnapshot = new CustomResourceSnapshot
CustomResources.AppHost (1)
TestResource.cs (1)
15.WithInitialState(new()
HealthChecksSandbox.AppHost (1)
Program.cs (1)
51.WithInitialState(new()
Stress.AppHost (2)
TestResource.cs (2)
16.WithInitialState(new() 33.WithInitialState(new()
43 references to CustomResourceSnapshot
Aspire.Hosting (38)
ApplicationModel\ResourceNotificationService.cs (19)
208static bool IsContinuableState(WaitBehavior waitBehavior, CustomResourceSnapshot snapshot) => 290static bool ShouldYield(WaitBehavior waitBehavior, CustomResourceSnapshot snapshot) => 352static bool IsKnownTerminalState(CustomResourceSnapshot snapshot) => 497/// Updates the snapshot of the <see cref="CustomResourceSnapshot"/> for a resource. 502public Task PublishUpdateAsync(IResource resource, string resourceId, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory) 508var previousState = GetCurrentSnapshot(resource, notificationState); 510var newState = stateFactory(previousState); 606private CustomResourceSnapshot UpdateCommands(IResource resource, CustomResourceSnapshot previousState) 669static ResourceCommandSnapshot CreateCommandFromAnnotation(ResourceCommandAnnotation annotation, CustomResourceSnapshot previousState, IServiceProvider serviceProvider) 678/// Updates the snapshot of the <see cref="CustomResourceSnapshot"/> for a resource. 682public async Task PublishUpdateAsync(IResource resource, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory) 691private static CustomResourceSnapshot GetCurrentSnapshot(IResource resource, ResourceNotificationState notificationState) 693var previousState = notificationState.LastSnapshot; 730public CustomResourceSnapshot? LastSnapshot { get; set; } 740public class ResourceEvent(IResource resource, string resourceId, CustomResourceSnapshot snapshot) 755public CustomResourceSnapshot Snapshot { get; } = snapshot;
ApplicationModel\ResourceSnapshotAnnotation.cs (2)
9public class ResourceSnapshotAnnotation(CustomResourceSnapshot initialSnapshot) : IResourceAnnotation 14public CustomResourceSnapshot InitialSnapshot { get; } = initialSnapshot ?? throw new ArgumentNullException(nameof(initialSnapshot));
CustomResourceExtensions.cs (2)
18/// <param name="initialSnapshot">The factory to create the initial <see cref="CustomResourceSnapshot"/> for this resource.</param> 20public static IResourceBuilder<TResource> WithInitialState<TResource>(this IResourceBuilder<TResource> builder, CustomResourceSnapshot initialSnapshot)
Dashboard\DashboardLifecycleHook.cs (1)
158var snapshot = new CustomResourceSnapshot()
Dashboard\DashboardServiceData.cs (1)
35static GenericResourceSnapshot CreateResourceSnapshot(IResource resource, string resourceId, DateTime creationTimestamp, CustomResourceSnapshot snapshot)
Dashboard\GenericResourceSnapshot.cs (1)
9internal sealed class GenericResourceSnapshot(CustomResourceSnapshot state) : ResourceSnapshot
Dashboard\ResourceSnapshot.cs (1)
47yield return (KnownProperties.Resource.HealthState, CustomResourceSnapshot.ComputeHealthStatus(HealthReports, State) is not { } healthStatus ? Value.ForNull() : Value.ForString(healthStatus.ToString()), IsSensitive: false);
Dcp\DcpExecutor.cs (2)
322private async Task ProcessResourceChange<T>(WatchEventType watchEventType, T resource, ConcurrentDictionary<string, T> resourceByName, string resourceKind, Func<T, CustomResourceSnapshot, CustomResourceSnapshot> snapshotFactory) where T : CustomResource
Dcp\DcpExecutorEvents.cs (2)
13internal record OnResourceChangedContext(CancellationToken CancellationToken, string ResourceType, IResource Resource, string DcpResourceName, ResourceStatus Status, Func<CustomResourceSnapshot, CustomResourceSnapshot> UpdateSnapshot);
Dcp\ResourceSnapshotBuilder.cs (4)
20public CustomResourceSnapshot ToSnapshot(Container container, CustomResourceSnapshot previous) 89public CustomResourceSnapshot ToSnapshot(Executable executable, CustomResourceSnapshot previous)
Orchestrator\ApplicationOrchestrator.cs (2)
140static Task PublishUpdateAsync(ResourceNotificationService notificationService, IResource resource, string? resourceId, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory)
ParameterResourceBuilderExtensions.cs (1)
161var state = new CustomResourceSnapshot()
Aspire.Hosting.Azure (2)
Provisioning\Provisioners\AzureProvisioner.cs (2)
106async Task UpdateStateAsync((IResource Resource, IAzureResource AzureResource) resource, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory)
Aspire.Hosting.Tests (3)
AddParameterTests.cs (1)
32var state = annotation.InitialSnapshot;
Health\HealthStatusTests.cs (1)
27var actualStatus = CustomResourceSnapshot.ComputeHealthStatus(reports, state);
ResourceNotificationTests.cs (1)
33var state = annotation.InitialSnapshot;