13 instantiations of CustomResourceSnapshot
Aspire.Hosting (4)
ApplicationModel\ResourceNotificationService.cs (1)
683
previousState ??= new
CustomResourceSnapshot
()
ConnectionStringBuilderExtensions.cs (1)
43
.WithInitialState(new
CustomResourceSnapshot
Dashboard\DashboardLifecycleHook.cs (1)
166
var snapshot = new
CustomResourceSnapshot
ParameterResourceBuilderExtensions.cs (1)
161
var state = new
CustomResourceSnapshot
Aspire.Hosting.Tests (3)
Backchannel\AppHostBackchannelTests.cs (1)
96
.WithInitialState(
new
() {
Dashboard\ResourcePublisherTests.cs (1)
185
return new GenericResourceSnapshot(
new
()
ResourceCommandAnnotationTests.cs (1)
58
ResourceSnapshot = new
CustomResourceSnapshot
CustomResources.AppHost (3)
TalkingClockResource.cs (2)
108
.WithInitialState(new
CustomResourceSnapshot
// Aspire type for custom resource state.
130
.WithInitialState(
new
()
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)
208
static bool IsContinuableState(WaitBehavior waitBehavior,
CustomResourceSnapshot
snapshot) =>
290
static bool ShouldYield(WaitBehavior waitBehavior,
CustomResourceSnapshot
snapshot) =>
352
static bool IsKnownTerminalState(
CustomResourceSnapshot
snapshot) =>
495
/// Updates the snapshot of the <see cref="
CustomResourceSnapshot
"/> for a resource.
500
public Task PublishUpdateAsync(IResource resource, string resourceId, Func<
CustomResourceSnapshot
,
CustomResourceSnapshot
> stateFactory)
506
var
previousState = GetCurrentSnapshot(resource, notificationState);
508
var
newState = stateFactory(previousState);
586
private
CustomResourceSnapshot
UpdateCommands(IResource resource,
CustomResourceSnapshot
previousState)
649
static ResourceCommandSnapshot CreateCommandFromAnnotation(ResourceCommandAnnotation annotation,
CustomResourceSnapshot
previousState, IServiceProvider serviceProvider)
658
/// Updates the snapshot of the <see cref="
CustomResourceSnapshot
"/> for a resource.
662
public async Task PublishUpdateAsync(IResource resource, Func<
CustomResourceSnapshot
,
CustomResourceSnapshot
> stateFactory)
671
private static
CustomResourceSnapshot
GetCurrentSnapshot(IResource resource, ResourceNotificationState notificationState)
673
var
previousState = notificationState.LastSnapshot;
710
public
CustomResourceSnapshot
? LastSnapshot { get; set; }
720
public class ResourceEvent(IResource resource, string resourceId,
CustomResourceSnapshot
snapshot)
735
public
CustomResourceSnapshot
Snapshot { get; } = snapshot;
ApplicationModel\ResourceSnapshotAnnotation.cs (2)
9
public class ResourceSnapshotAnnotation(
CustomResourceSnapshot
initialSnapshot) : IResourceAnnotation
14
public
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>
20
public static IResourceBuilder<TResource> WithInitialState<TResource>(this IResourceBuilder<TResource> builder,
CustomResourceSnapshot
initialSnapshot)
Dashboard\DashboardLifecycleHook.cs (1)
166
var
snapshot = new CustomResourceSnapshot
Dashboard\DashboardServiceData.cs (1)
34
static GenericResourceSnapshot CreateResourceSnapshot(IResource resource, string resourceId, DateTime creationTimestamp,
CustomResourceSnapshot
snapshot)
Dashboard\GenericResourceSnapshot.cs (1)
9
internal sealed class GenericResourceSnapshot(
CustomResourceSnapshot
state) : ResourceSnapshot
Dashboard\ResourceSnapshot.cs (1)
48
yield return (KnownProperties.Resource.HealthState,
CustomResourceSnapshot
.ComputeHealthStatus(HealthReports, State) is not { } healthStatus ? Value.ForNull() : Value.ForString(healthStatus.ToString()), IsSensitive: false);
Dcp\DcpExecutor.cs (2)
330
private 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)
13
internal record OnResourceChangedContext(CancellationToken CancellationToken, string ResourceType, IResource Resource, string DcpResourceName, ResourceStatus Status, Func<
CustomResourceSnapshot
,
CustomResourceSnapshot
> UpdateSnapshot);
Dcp\ResourceSnapshotBuilder.cs (4)
20
public
CustomResourceSnapshot
ToSnapshot(Container container,
CustomResourceSnapshot
previous)
89
public
CustomResourceSnapshot
ToSnapshot(Executable executable,
CustomResourceSnapshot
previous)
Orchestrator\ApplicationOrchestrator.cs (2)
169
static Task PublishUpdateAsync(ResourceNotificationService notificationService, IResource resource, string? resourceId, Func<
CustomResourceSnapshot
,
CustomResourceSnapshot
> stateFactory)
ParameterResourceBuilderExtensions.cs (1)
161
var
state = new CustomResourceSnapshot
Aspire.Hosting.Azure (2)
Provisioning\Provisioners\AzureProvisioner.cs (2)
64
async Task UpdateStateAsync((IResource Resource, IAzureResource AzureResource) resource, Func<
CustomResourceSnapshot
,
CustomResourceSnapshot
> stateFactory)
Aspire.Hosting.Tests (3)
AddParameterTests.cs (1)
32
var
state = annotation.InitialSnapshot;
Health\HealthStatusTests.cs (1)
27
var actualStatus =
CustomResourceSnapshot
.ComputeHealthStatus(reports, state);
ResourceNotificationTests.cs (1)
33
var
state = annotation.InitialSnapshot;