48 interfaces inheriting from IResource
Aspire.Hosting (15)
Aspire.Hosting.Azure (6)
Aspire.Hosting.Azure.Functions (1)
Aspire.Hosting.CodeGeneration.Go.Tests (5)
Aspire.Hosting.CodeGeneration.Java.Tests (5)
Aspire.Hosting.CodeGeneration.Python.Tests (5)
Aspire.Hosting.CodeGeneration.Rust.Tests (5)
Aspire.Hosting.CodeGeneration.TypeScript.Tests (6)
13 implementations of IResource
Aspire.Hosting (1)
Aspire.Hosting.Azure.AppConfiguration (1)
Aspire.Hosting.Azure.EventHubs (1)
Aspire.Hosting.Azure.ServiceBus (1)
Aspire.Hosting.Azure.SignalR (1)
Aspire.Hosting.Azure.Storage (1)
Aspire.Hosting.Azure.WebPubSub (1)
Aspire.Hosting.CodeGeneration.Python.Tests (2)
Aspire.Hosting.Tests (4)
1807 references to IResource
Aspire.Hosting (676)
ApplicationModel\ResourceCommandService.cs (6)
115public async Task<ExecuteCommandResult> ExecuteCommandAsync(IResource resource, string commandName, CancellationToken cancellationToken = default)
130public async Task<ExecuteCommandResult> ExecuteCommandAsync(IResource resource, string commandName, InteractionInputCollection arguments, CancellationToken cancellationToken = default)
230private static (InteractionInputCollection Arguments, string? ErrorMessage) CreateCommandArguments(IResource resource, string commandName, IReadOnlyDictionary<string, string?>? argumentValues)
313internal async Task<ExecuteCommandResult> ExecuteCommandAsync(IResource resource, string commandName, IReadOnlyDictionary<string, string?>? argumentValues, CancellationToken cancellationToken)
326internal async Task<ExecuteCommandResult> ExecuteCommandCoreAsync(string resourceId, IResource resource, string commandName, InteractionInputCollection arguments, bool argumentsProvided, bool nonInteractive, CancellationToken cancellationToken)
529private static ResourceCommandAnnotation? ResolveCommandAnnotation(IResource resource, ref string commandName, ILogger? logger = null)
ApplicationModel\ResourceExtensions.cs (90)
19/// Provides extension methods for the <see cref="IResource"/> interface.
31public static bool TryGetLastAnnotation<T>(this IResource resource, [NotNullWhen(true)] out T? annotation) where T : IResourceAnnotation
55public static bool TryGetAnnotationsOfType<T>(this IResource resource, [NotNullWhen(true)] out IEnumerable<T>? result) where T : IResourceAnnotation
78public static bool HasAnnotationOfType<T>(this IResource resource) where T : IResourceAnnotation
91public static bool TryGetAnnotationsIncludingAncestorsOfType<T>(this IResource resource, [NotNullWhen(true)] out IEnumerable<T>? result) where T : IResourceAnnotation
129public static bool HasAnnotationIncludingAncestorsOfType<T>(this IResource resource) where T : IResourceAnnotation
163public static bool TryGetEnvironmentVariables(this IResource resource, [NotNullWhen(true)] out IEnumerable<EnvironmentCallbackAnnotation>? environmentVariables)
267this IResource resource,
300IResource resource,
352this IResource resource,
392this IResource resource,
415this IResource resource,
449this IResource resource,
485this IResource resource,
510this IResource resource,
548where T : IResource, IComputeResource
568where T : IResource, IComputeResource
576internal static NetworkIdentifier GetDefaultResourceNetwork(this IResource resource)
581internal static IEnumerable<NetworkIdentifier> GetSupportedNetworks(this IResource resource)
587this IResource resource,
598(DistributedApplicationOperation.Run, IResourceBuilder<IResource> rb) when rb.Resource is IValueProvider provider => await resource.GetValue(executionContext, key, provider, logger, cancellationToken).ConfigureAwait(false),
600(DistributedApplicationOperation.Publish, IResourceBuilder<IResource> rb) when rb.Resource is IManifestExpressionProvider provider => new(provider.ValueExpression, false),
611public static bool IsExcludedFromPublish(this IResource resource) =>
615this IResource resource,
658private static async Task<ResolvedValue?> GetValue(this IResource resource, DistributedApplicationExecutionContext executionContext, string? key, IValueProvider valueProvider, ILogger logger, CancellationToken cancellationToken)
664if (valueProvider is IResource providerResource)
722public static bool TryGetContainerMounts(this IResource resource, [NotNullWhen(true)] out IEnumerable<ContainerMountAnnotation>? volumeMounts)
734public static bool TryGetEndpoints(this IResource resource, [NotNullWhen(true)] out IEnumerable<EndpointAnnotation>? endpoints)
746public static bool TryGetUrls(this IResource resource, [NotNullWhen(true)] out IEnumerable<ResourceUrlAnnotation>? urls)
755/// <returns>An enumeration of <see cref="EndpointReference"/> based on the <see cref="EndpointAnnotation"/> annotations from the resources' <see cref="IResource.Annotations"/> collection.</returns>
772/// <returns>An enumeration of <see cref="EndpointReference"/> based on the <see cref="EndpointAnnotation"/> annotations from the resources' <see cref="IResource.Annotations"/> collection.</returns>
839public static IReadOnlyList<ResolvedEndpoint> ResolveEndpoints(this IResource resource, IPortAllocator? portAllocator = null)
926public static bool TryGetContainerImageName(this IResource resource, [NotNullWhen(true)] out string? imageName)
939public static bool TryGetContainerImageName(this IResource resource, bool useBuiltImage, [NotNullWhen(true)] out string? imageName)
981public static int GetReplicaCount(this IResource resource)
1004public static bool RequiresImageBuild(this IResource resource)
1026public static bool RequiresImageBuildAndPush(this IResource resource)
1031internal static bool IsBuildOnlyContainer(this IResource resource)
1037internal static bool HasPrebuiltContainerImage(this IResource resource)
1049public static IComputeEnvironmentResource? GetComputeEnvironment(this IResource resource)
1063public static DeploymentTargetAnnotation? GetDeploymentTargetAnnotation(this IResource resource, IComputeEnvironmentResource? targetComputeEnvironment = null)
1117internal static Lifetime GetLifetimeType(this IResource resource)
1122private static Lifetime GetLifetimeType(IResource resource, HashSet<IResource> visitedResources)
1161internal static bool HasPersistentLifetime(this IResource resource)
1166internal static string GetOtelServiceInstanceId(this IResource resource, DcpInstance instance)
1178internal static bool TryGetParentProcessLifetime(this IResource resource, out int parentProcessId, out DateTime parentProcessTimestamp)
1183private static bool TryGetParentProcessLifetime(IResource resource, HashSet<IResource> visitedResources, out int parentProcessId, out DateTime parentProcessTimestamp)
1222internal static bool TryGetContainerImagePullPolicy(this IResource resource, [NotNullWhen(true)] out ImagePullPolicy? pullPolicy)
1240internal static bool SupportsProxy(this IResource resource)
1250internal static IResource GetRootResource(this IResource resource) =>
1261internal static string GetResolvedResourceName(this IResource resource)
1281internal static string GetResolvedDisplayResourceName(this IResource resource, string resourceId)
1292internal static bool TryGetInstances(this IResource resource, out ImmutableArray<DcpInstance> instances)
1309internal static string[] GetResolvedResourceNames(this IResource resource)
1329this IResource resource,
1369internal static IContainerRegistry GetContainerRegistry(this IResource resource)
1394var registryNames = string.Join(", ", registryTargetAnnotations.Select(a => a.Registry is IResource res ? res.Name : a.Registry.ToString()));
1416this IResource resource,
1459internal static ILogger GetLogger(this IResource resource, IServiceProvider serviceProvider)
1493public static Task<IReadOnlySet<IResource>> GetResourceDependenciesAsync(
1494this IResource resource,
1525public static Task<IReadOnlySet<IResource>> GetResourceDependenciesAsync(
1526this IResource resource,
1556internal static async Task<IReadOnlySet<IResource>> GetDependenciesAsync(
1557IEnumerable<IResource> resources,
1562var dependencies = new HashSet<IResource>();
1563var newDependencies = new HashSet<IResource>();
1564var toProcess = new Queue<IResource>();
1567foreach (var resource in resources)
1576foreach (var nd in newDependencies)
1583var dep = toProcess.Dequeue();
1588foreach (var newDep in newDependencies)
1600foreach (var resource in resources)
1618IResource resource,
1619HashSet<IResource> dependencies,
1620HashSet<IResource> newDependencies,
1643IResource resource,
1749private static void CollectAnnotationDependencies(IResource resource, HashSet<IResource> dependencies, HashSet<IResource> newDependencies)
1787HashSet<IResource> dependencies,
1788HashSet<IResource> newDependencies,
1799else if (reference is IResource resource && dependencies.Add(resource))
1867if (value is IResourceBuilder<IResource> resourceBuilder)
1883HashSet<IResource> dependencies,
1884HashSet<IResource> newDependencies,
1920internal static string GetResourceType(this IResource resource) => resource switch
ApplicationModel\ResourceNotificationService.cs (24)
147private async Task WaitUntilHealthyAsync(IResource resource, IResource dependency, WaitBehavior waitBehavior, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null)
327private async Task WaitUntilCompletionAsync(IResource resource, IResource dependency, int exitCode, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null)
401private async Task WaitUntilStateAsync(IResource resource, IResource dependency, WaitBehavior waitBehavior,
477private async Task WaitUntilStartedAsync(IResource resource, IResource dependency, WaitBehavior waitBehavior, CancellationToken cancellationToken, Func<string, Task>? onDependencyReady = null)
505public async Task WaitForDependenciesAsync(IResource resource, CancellationToken cancellationToken)
626private Task PublishWaitingForDependenciesAsync(IResource resource, IEnumerable<string> dependencyNames)
655private Task ClearWaitingForDependenciesAsync(IResource resource)
865public Task PublishUpdateAsync(IResource resource, string resourceId, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory)
992IResource resource,
1079IResource resource,
1127private CustomResourceSnapshot UpdateCommands(IResource resource, CustomResourceSnapshot previousState)
1207private static CustomResourceSnapshot UpdateIcons(IResource resource, CustomResourceSnapshot previousState)
1235private static CustomResourceSnapshot UpdateDashboardVisibility(IResource resource, CustomResourceSnapshot previousState)
1266public async Task PublishUpdateAsync(IResource resource, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory)
1275private static CustomResourceSnapshot GetCurrentSnapshot(IResource resource, ResourceNotificationState notificationState)
1303private ResourceNotificationState GetResourceNotificationState(string resourceId, IResource resource) =>
1425private sealed class ResourceNotificationState(IResource resource)
1430public IResource Resource { get; } = resource;
1479public class ResourceEvent(IResource resource, string resourceId, CustomResourceSnapshot snapshot)
1484public IResource Resource { get; } = resource;
Dcp\ContainerCreator.cs (10)
82foreach (var container in modelContainerResources)
151private static void ApplyMonitorProcess(IResource resource, ContainerSpec spec)
211var modelContainer = cr.ModelResource;
324internal async Task<IEnumerable<HostResourceWithEndpoints>> GetHostDependenciesAsync(IResource resource, CancellationToken cancellationToken)
341if (_model.Resources.TryGetByName(KnownResourceNames.AspireDashboard, out var dashboardResource)
587private async Task<(List<string>, bool)> BuildRunArgsAsync(ILogger resourceLogger, IResource modelResource, CancellationToken cancellationToken)
613private static async Task ApplyBuildArgumentsAsync(Container dcpContainerResource, IResource modelContainerResource, DistributedApplicationExecutionContext executionContext, ILogger logger, CancellationToken cancellationToken)
743private static List<VolumeMount> BuildContainerMounts(IResource container)
764private void EnsureRequiredAnnotations(IResource resource)
772public required IResource Resource { get; init; }
Dcp\DcpExecutor.cs (17)
217List<IResource> endpointAllocatedResources = [];
244foreach (var resource in endpointAllocatedResources.Distinct())
341internal static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource
738private static bool GetEffectiveIsProxied(IResource resource, EndpointAnnotation endpoint, bool randomizePorts)
814private static bool TryGetEffectiveFixedPublicPort(IResource resource, EndpointAnnotation endpoint, bool randomizePorts, out int publicPort)
836private void EnsureProxylessEndpointPort(IResource resource, EndpointAnnotation endpoint)
871private static bool NeedsPublicPort(IResource resource, EndpointAnnotation endpoint)
880private int? TryGetPersistedProxylessEndpointPort(IResource resource, EndpointAnnotation endpoint)
905private static string GetPersistedProxylessEndpointPortKey(IResource resource, EndpointAnnotation endpoint)
912internal static void SetInitialResourceState(IResource resource, IAnnotationHolder annotationHolder)
946var groupKey = group.Key;
957IResource modelResource,
1116internal static DcpInstance GetDcpInstance(IResource resource, int instanceIndex)
1379private static void ForgetCachedCallbackResults(IResource resource)
1406private void ForgetConnectionStringAvailableEvent(IResource resource)
1414private async Task<bool> PublishEndpointsAllocatedEventAsync(IResource resource, CancellationToken ct)
1429private async Task PublishConnectionStringAvailableEventAsync(IResource resource, CancellationToken ct)
Dcp\DcpExecutorEvents.cs (4)
11internal record OnResourceStartingContext(CancellationToken CancellationToken, string ResourceType, IResource Resource, string? DcpResourceName);
12internal record OnConnectionStringAvailableContext(CancellationToken CancellationToken, IResource Resource);
14internal record OnResourceChangedContext(CancellationToken CancellationToken, string ResourceType, IResource Resource, string DcpResourceName, ResourceStatus Status, string? PreviousState, Func<CustomResourceSnapshot, CustomResourceSnapshot> UpdateSnapshot);
15internal record OnResourceFailedToStartContext(CancellationToken CancellationToken, string ResourceType, IResource Resource, string? DcpResourceName, string? ErrorMessage = null);
Dcp\DcpNameGenerator.cs (8)
39public void EnsureDcpInstancesPopulated(IResource resource)
71private static void AddInstancesAnnotation(IResource resource, ImmutableArray<DcpInstance> instances)
76private static void ThrowIfPersistentExecutableHasReplicas(IResource resource)
89public (string Name, string Suffix) GetContainerName(IResource container)
100public (string Name, string Suffix) GetExecutableName(IResource project)
113public (string, bool) GetServiceName(IResource resource, EndpointAnnotation endpoint, NetworkIdentifier targetNetworkId)
171public static string GetObjectNameForResource(IResource resource, DcpOptions options, string suffix = "")
190private static string NetworkServiceKey(IResource resource, EndpointAnnotation endpoint, NetworkIdentifier targetNetworkId)
Diagnostics\ProfilingTelemetry.cs (13)
385IResource appModelResource,
402public static ActivityScope StartResourceBeforeStartWait(IConfiguration? configuration, IResource resource)
409public static ActivityScope StartResourceCreate(IConfiguration? configuration, IResource resource, string resourceKind, int replicaCount)
419IResource resource,
429public static ActivityScope StartResourceStart(IConfiguration? configuration, IResource resource, string resourceKind, string resourceName, string resourceType)
467public static ActivityScope StartResourceStop(IConfiguration? configuration, IResource resource, string resourceKind, string resourceName)
475public static ActivityScope StartResourceWaitForDependencies(IConfiguration? configuration, IResource resource, int dependencyCount)
483public static ActivityScope StartResourceWaitForDependency(IConfiguration? configuration, IResource resource, IResource dependency, WaitType waitType, WaitBehavior? waitBehavior)
993public void SetDependencyWait(IResource resource, IResource dependency, WaitType waitType, WaitBehavior? waitBehavior)
1017public void SetResource(IResource resource)
1033public void SetResourceLifecycle(IResource resource, string resourceId, CustomResourceSnapshot snapshot)
Orchestrator\ApplicationOrchestrator.cs (16)
25private readonly ILookup<IResource, IResource> _parentChildLookup;
208private async Task PublishResourceEndpointUrls(IResource resource, CancellationToken cancellationToken)
218private static IEnumerable<UrlSnapshot> GetResourceUrls(IResource resource)
283static Task PublishUpdateAsync(ResourceNotificationService notificationService, IResource resource, string? resourceId, Func<CustomResourceSnapshot, CustomResourceSnapshot> stateFactory)
301private async Task ProcessResourceUrlCallbacks(IResource resource, CancellationToken cancellationToken)
679private async Task SetChildResourceAsync(IResource resource, string? state, DateTime? startTimeStamp, DateTime? stopTimeStamp)
681foreach (var child in _parentChildLookup[resource].Where(c => c is IResourceWithParent))
708foreach (var resource in _model.Resources)
712var parent = resource is IResourceWithParent hasParent
734private static ImmutableArray<HealthReportSnapshot> GetInitialHealthReports(IResource resource)
745private async Task PublishConnectionStringAvailableEvent(IResource resource, CancellationToken cancellationToken)
771private async Task PublishEventToHierarchy<TEvent>(Func<IResource, TEvent> createEvent, IResource resource, CancellationToken cancellationToken)
780foreach (var child in children.Where(c => c is IResourceWithParent))
795private static bool ResourceHasOwnLifetime(IResource resource) =>
Orchestrator\RelationshipEvaluator.cs (19)
13public static ILookup<IResource, IResource> GetParentChildLookup(DistributedApplicationModel model)
18.Select(x => (Child: (IResource)x, Parent: x.Parent))
24private static IEnumerable<(IResource Child, IResource Parent)> GetParentChildRelationshipsFromAnnotations(DistributedApplicationModel model)
26static bool TryGetParent(IResource resource, [NotNullWhen(true)] out IResource? parent)
39static IResource? SelectParentResource(IResource? resource) => resource switch
41IResource r when TryGetParent(r, out var parent) => parent,
54private static void ValidateRelationships((IResource Child, IResource Parent)[] relationships)
64var visited = new Stack<IResource>();
70static void ValidateNoCircularDependencies(Dictionary<IResource, IResource> childToParentLookup, IResource child, Stack<IResource> visited)
73if (childToParentLookup.TryGetValue(child, out var parent))
Publishing\ResourceContainerImageManager.cs (19)
150Task BuildImageAsync(IResource resource, CancellationToken cancellationToken = default);
158Task BuildImagesAsync(IEnumerable<IResource> resources, CancellationToken cancellationToken = default);
165Task PushImageAsync(IResource resource, CancellationToken cancellationToken);
171IResource resource,
272IResource resource,
297public async Task BuildImagesAsync(IEnumerable<IResource> resources, CancellationToken cancellationToken = default)
303foreach (var resource in resourceList)
335foreach (var resource in resourcesToBuild)
344public async Task BuildImageAsync(IResource resource, CancellationToken cancellationToken = default)
421IResource resource,
428IResource resource,
553IResource resource,
714IResource resource,
767IResource resource,
903IResource resource,
938private async Task BuildContainerImageFromDockerfileAsync(IResource resource, DockerfileBuildAnnotation dockerfileBuildAnnotation, string imageName, ResolvedContainerBuildOptions options, CancellationToken cancellationToken)
1029public async Task PushImageAsync(IResource resource, CancellationToken cancellationToken)
1036private async Task<bool> ResourcesRequireContainerRuntimeAsync(IEnumerable<IResource> resources, CancellationToken cancellationToken)
1038foreach (var resource in resources)
ResourceBuilderExtensions.cs (101)
78where T : IResource
110where T : IResource
134where T : IResource
135where TSource : IResource
183where T : IResource
206where T : IResource
227where T : IResource
730where T : IResource
748internal static IResource WithSerializedAnnotation(this IResource resource, string annotationId, string json)
768where T : IResource
782internal static string GetSerializedAnnotation(this IResource resource, string annotationId)
799where T : IResource
813internal static bool HasSerializedAnnotation(this IResource resource, string annotationId)
831where T : IResource
851where T : IResource
865internal static TData GetAnnotation<TData>(this IResource resource, AnnotationDefinition<TData> definition)
884internal static bool TryGetAnnotation<TData>(this IResource resource, AnnotationDefinition<TData> definition, [NotNullWhen(true)] out TData? data)
923private static string? TryGetSerializedAnnotation(IResource resource, string annotationId)
931private static void RemoveSerializedAnnotation(IResource resource, string annotationId)
1009public static IResourceBuilder<T> WithManifestPublishingCallback<T>(this IResourceBuilder<T> builder, Action<ManifestPublishingContext> callback) where T : IResource
1027public static IResourceBuilder<T> WithManifestPublishingCallback<T>(this IResourceBuilder<T> builder, Func<ManifestPublishingContext, Task> callback) where T : IResource
1164[AspireUnion(typeof(IResourceBuilder<IResource>), typeof(EndpointReference), typeof(string), typeof(Uri))] object source,
1175IResourceBuilder<IResource> resourceBuilder => WithReferenceResource(builder, resourceBuilder, connectionName, optional, name),
1189IResourceBuilder<IResource> source,
1203IResourceBuilder<IResource> source,
1284IResourceBuilder<IResource> source,
1301IResourceBuilder<IResource> source,
1327IResourceBuilder<IResource> source,
1332where TCustom : class, IResource, IResourceWithCustomWithReference<TCustom>
2291where T : IResource
2315where T : IResource
2353where T : IResource
2387where T : IResource
2415where T : IResource
2438where T : IResource
2496where T : IResource
2584where T : IResource
2700public static IResourceBuilder<T> ExcludeFromManifest<T>(this IResourceBuilder<T> builder) where T : IResource
2718/// resources, calling <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource})"/> also results
2735public static IResourceBuilder<T> WaitFor<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency) where T : IResourceWithWaitSupport
2749IResourceBuilder<IResource> dependency,
2772/// resources, calling <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource}, WaitBehavior)"/> also results
2780/// behavior with the <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource})"/> overload.</para>
2795public static IResourceBuilder<T> WaitFor<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency, WaitBehavior waitBehavior) where T : IResourceWithWaitSupport
2803private static IResourceBuilder<T> WaitForCore<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency, WaitBehavior? waitBehavior, bool addRelationship) where T : IResourceWithWaitSupport
2805if (builder.Resource as IResource == dependency.Resource)
2845/// <para>Unlike <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource})"/>, this method
2860public static IResourceBuilder<T> WaitForStart<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency) where T : IResourceWithWaitSupport
2874IResourceBuilder<IResource> dependency,
2897/// <para>Unlike <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource}, WaitBehavior)"/>, this method
2903/// behavior with the <see cref="WaitForStart{T}(IResourceBuilder{T}, IResourceBuilder{IResource})"/> overload.</para>
2918public static IResourceBuilder<T> WaitForStart<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency, WaitBehavior waitBehavior) where T : IResourceWithWaitSupport
2926private static IResourceBuilder<T> WaitForStartCore<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency, WaitBehavior? waitBehavior, bool addRelationship) where T : IResourceWithWaitSupport
2928if (builder.Resource as IResource == dependency.Resource)
2953foreach (var referencedResource in cs.ConnectionStringExpression.ValueProviders.OfType<IResource>())
2992public static IResourceBuilder<T> WithExplicitStart<T>(this IResourceBuilder<T> builder) where T : IResource
3026public static IResourceBuilder<T> WaitForCompletion<T>(this IResourceBuilder<T> builder, IResourceBuilder<IResource> dependency, int exitCode = 0) where T : IResourceWithWaitSupport
3031if (builder.Resource as IResource == dependency.Resource)
3058/// the <see cref="WaitFor{T}(IResourceBuilder{T}, IResourceBuilder{IResource})"/> to associate a resource
3086public static IResourceBuilder<T> WithHealthCheck<T>(this IResourceBuilder<T> builder, string key) where T : IResource
3288CommandOptions? commandOptions = null) where T : IResource
3358bool isHighlighted = false) where T : IResource
3433where TResource : IResource
3496where TResource : IResource
3554where TResource : IResource
3599where TResource : IResource
3637where TResource : IResource
4728where TResource : IResource
4848IResource resource,
4849string type) where T : IResource
4874IResourceBuilder<IResource> resourceBuilder,
4875string type) where T : IResource
4894IResource resource) where T : IResource
4913ReferenceExpression expression) where T : IResource
4924where T : IResource
4928void AddReference(IResource resource)
4940if (value is IResource resource)
4944else if (value is IResourceBuilder<IResource> resourceBuilder)
4974IResourceBuilder<IResource> resourceBuilder) where T : IResource
5010IResourceBuilder<IResource> parent) where T : IResource
5042IResource parent) where T : IResource
5076IResourceBuilder<IResource> child) where T : IResource
5110IResource child) where T : IResource
5147public static IResourceBuilder<T> WithIconName<T>(this IResourceBuilder<T> builder, string iconName, IconVariant iconVariant = IconVariant.Filled) where T : IResource
5315where T : IResource
5355where T : IResource
5412where T : IResource
5607public static IResourceBuilder<T> ExcludeFromMcp<T>(this IResourceBuilder<T> builder) where T : IResource
5627public static IResourceBuilder<T> WithHidden<T>(this IResourceBuilder<T> builder) where T : IResource
5647public static IResourceBuilder<T> WithHiddenOnCompletion<T>(this IResourceBuilder<T> builder, int exitCode) where T : IResource
5670internal static IResourceBuilder<T> WithHiddenOnCompletionExport<T>(this IResourceBuilder<T> builder, int? exitCode = null, int[]? exitCodes = null) where T : IResource
5692public static IResourceBuilder<T> WithHiddenOnCompletion<T>(this IResourceBuilder<T> builder, params int[] exitCodes) where T : IResource
5700private static IResourceBuilder<T> WithHiddenOnCompletionCore<T>(IResourceBuilder<T> builder, IReadOnlyList<int> exitCodes) where T : IResource
Aspire.Hosting.Azure (76)
AzureProvisioningController.cs (50)
961private static void ThrowIfNonArmTarget(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> resources)
1071IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources,
1137private static bool HasMissingAzureContextFailure(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources)
1141private static ImmutableArray<ResourcePropertySnapshot> CreateAzureEnvironmentFailureProperties(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources)
1155private static Exception? GetProvisioningFailureException(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources)
1160private static string CreateProvisioningFailureMessage(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources)
1174IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources,
1191IReadOnlyCollection<(IResource Resource, IAzureResource AzureResource)> azureResources,
1265private static List<(IResource Resource, IAzureResource AzureResource)> GetProvisionableAzureResources(DistributedApplicationModel model)
1276private static List<(IResource Resource, IAzureResource AzureResource)> GetTargetAzureResources(
1293var queue = new Queue<(IResource Resource, IAzureResource AzureResource)>();
1294var targetResources = new List<(IResource Resource, IAzureResource AzureResource)>();
1306foreach (var child in parentChildLookup[current.Resource])
1316foreach (var child in parentChildLookup[current.AzureResource])
1339void Enqueue((IResource Resource, IAzureResource AzureResource) resource)
1348private static ILookup<IResource, IResource> GetTargetParentChildLookup(DistributedApplicationModel model, bool includeAnnotationParentRelationships)
1358private static IEnumerable<IResource> GetResourceParents(IResource resource, bool includeAnnotationParentRelationships)
1384private static void ThrowIfKeyVaultLocationChangeTarget(IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> targetResources)
1405IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources,
1406IResource target,
1407out (IResource Resource, IAzureResource AzureResource) azureResource)
1422private static List<(IResource Resource, IAzureResource AzureResource)> GetActiveOperationTargetAzureResources(DistributedApplicationModel model, ActiveAzureOperation activeOperation)
1913IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> resources, CancellationToken cancellationToken)
2910private static string GetDeploymentStateResourceName((IResource Resource, IAzureResource AzureResource) resource)
2914IReadOnlyCollection<(IResource Resource, IAzureResource AzureResource)> targetResources,
3015IReadOnlyCollection<(IResource Resource, IAzureResource AzureResource)> targetResources,
3504private bool ShouldCheckForDrift(IResource resource)
3736private CustomResourceSnapshot ApplyActiveOperationProperties(IResource resource, CustomResourceSnapshot state)
3767foreach (var resource in GetResourcesForCommandStateRefresh(model))
3775private static IEnumerable<IResource> GetResourcesForCommandStateRefresh(DistributedApplicationModel model)
3778var resources = new List<IResource>();
3795void Add(IResource resource)
3805(IResource Resource, IAzureResource AzureResource) resource,
3806ILookup<IResource, IResourceWithParent> parentChildLookup,
3809async Task PublishAsync(IResource targetResource)
3845(IResource Resource, IAzureResource AzureResource) resource,
3846ILookup<IResource, IResourceWithParent> parentChildLookup)
3898IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> targetResources,
3916(IResource Resource, IAzureResource AzureResource) resource,
3917ILookup<IResource, IResourceWithParent> parentChildLookup)
3985(IResource Resource, IAzureResource AzureResource) resource,
3986ILookup<IResource, IResourceWithParent> parentChildLookup)
4015IReadOnlyList<(IResource Resource, IAzureResource AzureResource)> azureResources,
4016ILookup<IResource, IResourceWithParent> parentChildLookup,
4038(IResource Resource, IAzureResource AzureResource) resource,
4039ILookup<IResource, IResourceWithParent> parentChildLookup,
4227IResource targetResource,
4228ILookup<IResource, IResourceWithParent> parentChildLookup,
AzureResourcePreparer.cs (15)
76private static void AddPerResourceCommands(List<(IResource Resource, IAzureResource AzureResource)> azureResources)
119private static string GetDeploymentStateResourceName((IResource Resource, IAzureResource AzureResource) resource)
155IResource resource,
181internal static List<(IResource Resource, IAzureResource AzureResource)> GetAzureResourcesFromAppModel(DistributedApplicationModel appModel)
188var azureResources = new List<(IResource, IAzureResource)>();
189foreach (var resource in appModel.Resources)
220foreach (var resource in appModel.Resources)
234private async Task BuildRoleAssignmentAnnotations(DistributedApplicationModel appModel, List<(IResource Resource, IAzureResource AzureResource)> azureResources, CancellationToken cancellationToken)
264foreach (var resource in resourceSnapshot)
326foreach (var dependency in directDependencies)
414private static Dictionary<AzureProvisioningResource, IEnumerable<RoleDefinition>> GetAllRoleAssignments(IResource resource)
433IResource resource,
463IResource resource,
561if (!appModel.Resources.TryGetByName(roleAssignmentResource.Name, out var existingResource))
579private static void AddDeploymentPrerequisitesAnnotation(IResource resource, HashSet<AzureBicepResource> prerequisiteResources)
Aspire.Hosting.Azure.AppConfiguration (4)
Aspire.Hosting.Azure.AppContainers (28)
Aspire.Hosting.Azure.AppService (25)
Aspire.Hosting.Azure.CognitiveServices (4)
Aspire.Hosting.Azure.ConnectorNamespace (1)
Aspire.Hosting.Azure.ContainerRegistry (7)
Aspire.Hosting.Azure.EntraId (21)
EntraIdApplicationResource.cs (18)
207internal List<IResource> Consumers { get; } = [];
275foreach (var consumer in Consumers)
286internal static void ValidateConsumerReferences(IResource consumer)
315foreach (var target in ClientCredentials.OfType<EntraIdFederatedIdentityCredential>().Select(c => c.ComputeTarget).OfType<IResource>())
332IEnumerable<IResource> targets = credential.ComputeTarget is { } target ? [target] : Consumers;
333foreach (var resource in targets)
927internal virtual bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
964internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
1043internal IResource? ComputeTarget { get; set; }
1051internal static AzureUserAssignedIdentityResource? GetConsumerIdentity(IResource consumer)
1056internal void ValidateConsumer(EntraIdApplicationResource application, IResource consumer)
1074IResource consumer) : IValueProvider, IManifestExpressionProvider, IValueWithReferences, IBicepOutputReferenceProvider
1098internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
1181internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
1236internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
1294internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
1330internal override bool EmitEnvironmentVariables(IDictionary<string, object> envVars, string prefix, string separator, EntraIdApplicationResource application, IResource consumer, DistributedApplicationExecutionContext executionContext)
Aspire.Hosting.Azure.EntraId.Tests (4)
Aspire.Hosting.Azure.EventHubs (4)
Aspire.Hosting.Azure.FrontDoor (2)
Aspire.Hosting.Azure.Functions (16)
Aspire.Hosting.Azure.KeyVault (6)
Aspire.Hosting.Azure.Kubernetes (2)
Aspire.Hosting.Azure.Kusto (3)
Aspire.Hosting.Azure.Network (2)
Aspire.Hosting.Azure.Sandboxes (32)
AzureSandboxContainerDeployment.cs (18)
86internal static PipelineStep CreateStaleCleanupPipelineStep(IResource resource, IReadOnlySet<string> activeStateSectionNames)
103foreach (var resource in model.GetComputeResources())
158foreach (var dependency in dependencies)
239var targetResource = resource.TargetResource;
771private static List<AzureDevComputeIdentitySetting>? ResolveIdentitySettings(IResource resource)
792private static void AddManagedIdentityEnvironmentVariables(IResource resource, Dictionary<string, string> environmentVariables)
921internal static void ValidateSandboxCompatibility(IResource resource)
1043private static async Task<ContainerImageMetadata> ResolveContainerImageMetadataAsync(PipelineStepContext context, IResource resource, string imageReference)
1065internal static async Task<ResolvedModeledCommand> ResolveModeledCommandAsync(PipelineStepContext context, IResource resource)
1099internal static bool HasModeledCommandConfiguration(IResource resource) =>
1137internal static async Task<ResolvedEnvironmentVariables> ResolveEnvironmentVariablesAsync(PipelineStepContext context, IResource resource)
1165internal static async Task<string> ResolveValueAsync(PipelineStepContext context, IResource resource, object? value)
1168internal static async Task<ResolvedValue> ResolveValueWithEgressHostsAsync(PipelineStepContext context, IResource resource, object? value)
1218IResource resource,
1250IResource resource,
1559internal static int? ResolveSandboxTargetPort(IResource resource, ResolvedEndpoint endpoint)
1574private static string ResolveSandboxPortProtocol(IResource resource, EndpointAnnotation endpoint)
2357private static AzureSandboxOptions? GetAzureSandboxContainerOptions(IResource resource)
Aspire.Hosting.Azure.Search (4)
Aspire.Hosting.Azure.ServiceBus (5)
Aspire.Hosting.Azure.SignalR (4)
Aspire.Hosting.Azure.Sql (4)
Aspire.Hosting.Azure.Storage (4)
Aspire.Hosting.Azure.Tests (117)
AzureRunAsEmulatorModeTests.cs (5)
12public static TheoryData<string, Func<IDistributedApplicationBuilder, Action, IResource>> RunAsEmulatorResources => new()
27public void RunAsEmulator_InRunMode_ConfiguresLocalContainer(string resourceType, Func<IDistributedApplicationBuilder, Action, IResource> addResource)
32var resource = addResource(builder, () => callbackInvoked = true);
41public void RunAsEmulator_InPublishMode_DoesNotConfigureLocalContainer(string resourceType, Func<IDistributedApplicationBuilder, Action, IResource> addResource)
46var resource = addResource(builder, () => callbackInvoked = true);
AzureSandboxesTests.cs (13)
477var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2018var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2184var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2246var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2285var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2309var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "cache");
2352var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2353var explicitComputeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "backend");
2456var cleanupResource = Assert.Single(model.Resources, resource => resource.Name == "azure-sandbox-cleanup");
2534var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2597var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
2865var computeResource = Assert.Single(model.GetComputeResources(), resource => resource.Name == "frontend");
3322IResource resource,
AzureServiceBusExtensionsTests.cs (16)
607var sql = builder.Resources.FirstOrDefault(x => x.Name == "sb-mssql");
611var sourceResource = GetPersistenceReferenceSource(sql);
625var sql = builder.Resources.FirstOrDefault(x => x.Name == "sb-mssql");
647var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
669var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
681var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
695var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
712var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
727var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
826var sql = Assert.Single(builder.Resources, x => x.Name == "sb-mssql");
968private static IResource GetPersistenceReferenceSource(IResource resource)
971return Assert.IsAssignableFrom<IResource>(annotation.SourceResource);
974private static void AssertWaitsForHealthy(IResource resource, IResource dependency)
981private static void AllocateContainerNetworkEndpoint(IResource resource, string address, int port)
Aspire.Hosting.Azure.WebPubSub (4)
Aspire.Hosting.Blazor (17)
Aspire.Hosting.Blazor.Tests (18)
Aspire.Hosting.CodeGeneration.Go.Tests (25)
Aspire.Hosting.CodeGeneration.Java.Tests (24)
Aspire.Hosting.CodeGeneration.Python.Tests (24)
Aspire.Hosting.CodeGeneration.Rust.Tests (24)
Aspire.Hosting.CodeGeneration.TypeScript.Tests (26)
Aspire.Hosting.Containers.Tests (14)
Aspire.Hosting.DevTunnels (7)
Aspire.Hosting.DevTunnels.Tests (3)
Aspire.Hosting.Docker (30)
Aspire.Hosting.Docker.Tests (14)
Aspire.Hosting.Dotnet (25)
DotnetProjectBuildCoordinator.cs (15)
183IResource buildResource,
748private static Action ApplyBuildEnvironment(IResource target, SharedBuildEnvironment sharedBuildEnvironment)
756IResource target,
769IResource target,
781private static Action ApplyBuildProperties(IResource target, SharedBuildEnvironment sharedBuildEnvironment)
796IResource target,
828private static IResource? FindRebuilder(
834candidate is IResourceWithParent<IResource> parent &&
878private readonly Dictionary<IResource, MsBuildResponseFile> _responseFiles =
907IResource resource,
1024public void ReleaseResponseFile(IResource resource)
1219IResource resource,
1251IResource resource,
1294private void ReleaseResponseFile(IResource resource, MsBuildResponseFile expectedResponseFile)
1310private void ReplaceResponseFile(IResource resource, MsBuildResponseFile responseFile)
Aspire.Hosting.Dotnet.Tests (4)
Aspire.Hosting.EntityFrameworkCore (4)
Aspire.Hosting.EntityFrameworkCore.Tests (2)
Aspire.Hosting.Foundry (17)
Aspire.Hosting.Foundry.Tests (5)
Aspire.Hosting.Go (3)
Aspire.Hosting.Go.Tests (7)
Aspire.Hosting.Java (1)
Aspire.Hosting.Java.Tests (6)
Aspire.Hosting.JavaScript (7)
Aspire.Hosting.JavaScript.Tests (10)
Aspire.Hosting.Kafka.Tests (1)
Aspire.Hosting.Keycloak.Tests (2)
Aspire.Hosting.Kubernetes (53)
KubernetesEnvironmentResource.cs (18)
187internal sealed record CapturedHelmImageReference(string Section, string ResourceKey, string ValueKey, IResource Resource);
209internal sealed record TlsSecretRequest(ReferenceExpression SecretName, ReferenceExpression Hostname, IResource Owner);
336foreach (var computeResource in resources)
339var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(targetEnv)?.DeploymentTarget;
373foreach (var computeResource in resources)
376var deploymentTarget = computeResource.GetDeploymentTargetAnnotation(targetEnv)?.DeploymentTarget;
462var deploymentTargets = new Dictionary<IResource, KubernetesResource>(new ResourceNameComparer());
464foreach (var r in appModel.GetComputeResources())
549private static void ConfigureOtlp(IResource resource, KubernetesAspireDashboardResource dashboard)
575IResource resource,
589private static OtlpExporterAnnotation? GetEffectiveOtlpExporterAnnotation(IResource resource)
723private async Task ProcessIngressResources(DistributedApplicationModel model, Dictionary<IResource, KubernetesResource> deploymentTargets, ILogger logger, CancellationToken cancellationToken)
763Dictionary<IResource, KubernetesResource> deploymentTargets,
928Dictionary<IResource, KubernetesResource> deploymentTargets,
964private async Task ProcessGatewayResources(DistributedApplicationModel model, Dictionary<IResource, KubernetesResource> deploymentTargets, ILogger logger, CancellationToken cancellationToken)
1098Dictionary<IResource, KubernetesResource> deploymentTargets,
1274Dictionary<IResource, KubernetesResource> deploymentTargets,
1359internal static bool OwnerWasMaterialized(IResource owner) => owner switch
Aspire.Hosting.Kubernetes.Tests (7)
Aspire.Hosting.Maui (13)
Aspire.Hosting.Maui.Tests (28)
MauiBuildQueueTests.cs (13)
1110private static void AddOriginalStopCommand(IResource resource, Action? onExecute = null)
1119private static void AddOriginalStopCommand(IResource resource, Func<ExecuteCommandContext, Task<ExecuteCommandResult>> executeCommand)
1160private static async Task WaitForStateAsync(BuildQueueTestEnvironment env, IResource resource, string state)
1207public Task WaitForBuildStartedAsync(IResource resource, TimeSpan? timeout = null)
1213public void CompleteBuild(IResource resource)
1219public void CompleteBuildImmediately(IResource resource)
1224public bool GetReleaseOnRunning(IResource resource)
1229public CancellationToken GetLaunchCancellationToken(IResource resource)
1235public void FailBuild(IResource resource, string message)
1242public void FailBuildWith(IResource resource, Exception exception)
1248internal override async Task RunBuildAsync(IResource resource, ILogger logger, CancellationToken cancellationToken)
1283internal override Task ReleaseSemaphoreAfterLaunchAsync(IResource resource, SemaphoreSlim semaphore, string? stateAtCallTime, bool releaseOnRunning, ILogger logger, CancellationToken cancellationToken)
1318internal override Task ReleaseSemaphoreAfterLaunchAsync(IResource resource, SemaphoreSlim semaphore, string? stateAtCallTime, bool releaseOnRunning, ILogger logger, CancellationToken cancellationToken)
Aspire.Hosting.Milvus.Tests (2)
Aspire.Hosting.MySql (1)
Aspire.Hosting.MySql.Tests (4)
Aspire.Hosting.Oracle.Tests (3)
Aspire.Hosting.Orleans.Tests (1)
Aspire.Hosting.PostgreSQL (3)
Aspire.Hosting.PostgreSQL.Tests (9)
Aspire.Hosting.Python.Tests (1)
Aspire.Hosting.Qdrant (1)
Aspire.Hosting.Qdrant.Tests (6)
Aspire.Hosting.Radius (85)
Publishing\RadiusInfrastructureBuilder.cs (64)
60private readonly Dictionary<ParameterResource, List<IResource>> _rabbitMqUserNames = new(ReferenceEqualityComparer.Instance);
103private readonly Dictionary<ParameterResource, (IResource Owner, bool IsProjectionSubstitution)> _recipeCredentialOwners = [];
107private readonly HashSet<(IResource Resource, ParameterResource Parameter)> _warnedUnrelatedSubstitutions = [];
122private readonly List<(IResource Resource, string RadiusType)> _databasesNotCreatedByTheRecipe = [];
136private readonly List<(IResource Resource, string SelectedDatabaseName)> _recipeDatabaseSelections = [];
256foreach (var resource in radiusResources)
380foreach (var resource in radiusResources)
414foreach (var resource in computeResources)
604private Dictionary<ParameterResource, IReadOnlyList<IResource>> BuildLiveRabbitMqUserNames(RadiusInfrastructureOptions options)
606var live = new Dictionary<ParameterResource, IReadOnlyList<IResource>>(ReferenceEqualityComparer.Instance);
1668private (string ResourceType, string ApiVersion) ResolveResourceType(IResource resource)
1672private (List<IResource> radiusResources, List<IResource> computeResources, Dictionary<IResource, (string ResourceType, string ApiVersion)> resolvedTypes) ClassifyResources()
1674var radiusTypes = new List<IResource>();
1675var compute = new List<IResource>();
1676var resolved = new Dictionary<IResource, (string ResourceType, string ApiVersion)>();
1679foreach (var resource in _model.Resources)
1695var resolvedResource = ResolveToParent(resource);
1732private bool IsTargetedToThisEnvironment(IResource resource)
1751private static IResource ResolveToParent(IResource resource)
2048private static string GetContainerImage(IResource resource)
2114List<IResource> radiusResources,
2121foreach (var resource in radiusResources)
2211IResource resource,
2298private void RecordIfDatabaseIsNotCreatedByTheRecipe(IResource resource, string radiusType)
2389IResource resource,
2452IResource resource,
2661IResource resource,
2863internal static RadiusBackingResourceProjectionException CreateRabbitMqGuestUserNameException(IResource resource) =>
2923foreach (var resource in _model.Resources)
2952private void WarnIfUserSuppliedCredentialIsReplaced(IResource resource, ParameterResource parameter, string credentialKind)
2984private void WarnIfUnrelatedUseOfSubstitutedParameter(ParameterResource parameter, IResource resource)
3045private IResource ResolveEnvValueProvenance(
3048IResource resource,
3049Dictionary<IResource, HashSet<string>> referencePrefixes)
3108private static Dictionary<IResource, HashSet<string>> BuildReferencePrefixes(IResource resource, Dictionary<string, object> environmentVariables)
3110var prefixes = new Dictionary<IResource, HashSet<string>>();
3135void Add(IResource target, string connectionName)
3175private bool ModelHasPotentialConsumer(IResource resource, List<IResourceWithConnectionString> databaseChildren) =>
3186private List<IResourceWithConnectionString> FindDatabaseChildren(IResource resource) =>
3339var resource = ResolveToParent(endpointReference.Resource);
3409IResource resource,
3421IResource resource,
3461IResource resource,
3496private static void ThrowIfNotPrimaryEndpoint(EndpointReference endpointReference, IResource resource, string radiusType)
3516IResource resource,
3517List<IResource> radiusResources,
3529var referencedResource = reference.Resource;
3590private static Dictionary<string, ContainerPortConstruct> ResolvePorts(IResource resource)
3642IResource resource,
3826private static string ToSecretKey(IResource resource, string envVarName)
3855IResource resource,
4125private async Task ResolveEnvPartsAsync(object? value, IResource owner, List<EnvPart> parts, IResource referencedResource, bool allowRecipeSubstitutions = true)
4242private void RecordConnectionStringConsumption(IResourceWithConnectionString consumed, IResource owner)
4274private void RecordConnectionStringExpressionConsumption(ReferenceExpression expression, IResource owner)
4327private static void ThrowIfEndpointMissing(EndpointReference endpointReference, IResource owner)
4345private async Task ResolveReferenceExpressionPartsAsync(ReferenceExpression expression, IResource owner, List<EnvPart> parts, IResource referencedResource, bool allowRecipeSubstitutions = true)
4592private void RegisterRecipeCredential(ParameterResource parameter, IResource owner, bool isProjectionSubstitution)
4740private EnvPart ResolveParameterPart(ParameterResource parameter, IResource owner, bool allowRecipeSubstitutions)
Aspire.Hosting.Radius.Tests (15)
Aspire.Hosting.Redis (2)
Aspire.Hosting.Redis.Tests (5)
Aspire.Hosting.RemoteHost.Tests (8)
Aspire.Hosting.Rust.Tests (1)
Aspire.Hosting.SqlServer (1)
Aspire.Hosting.Testing (11)
Aspire.Hosting.Testing.Tests (3)
Aspire.Hosting.Tests (127)
ApplicationModel\ResourceCollectionTests.cs (13)
17var found = collection.TryGetByName("myResource", out var result);
30var found = collection.TryGetByName("MYRESOURCE", out var result);
42var found = collection.TryGetByName("missing", out var result);
53var found = collection.TryGetByName("anything", out var result);
122Assert.True(collection.TryGetByName("res2", out var result));
136Assert.True(collection.TryGetByName("new", out var result));
190Assert.True(collection.TryGetByName("res", out var result));
197var resources = new IResource[]
209var resources = new IResource[]
216Assert.True(collection.TryGetByName("res1", out var r1));
219Assert.True(collection.TryGetByName("res2", out var r2));
232Assert.True(collection.TryGetByName("test", out var result));
248private sealed class SimpleResourceCollection : Collection<IResource>, IResourceCollection
Dashboard\DashboardEventHandlersTests.cs (10)
55var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName));
104var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName));
196var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName));
481var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName));
564var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName));
637var dashboardResource = Assert.Single(model.Resources);
721var dashboardResource = Assert.Single(model.Resources);
790var dashboardResource = Assert.Single(model.Resources);
857var dashboardResource = Assert.Single(model.Resources);
901var dashboardResource = Assert.Single(model.Resources);
Dashboard\DashboardResourceTests.cs (16)
126var dashboard = Assert.Single(model.Resources);
227var dashboard = Assert.Single(model.Resources);
261var dashboard = Assert.Single(model.Resources);
304var dashboard = Assert.Single(model.Resources);
332var dashboard = Assert.Single(model.Resources);
401var dashboard = Assert.Single(model.Resources);
441var dashboard = Assert.Single(model.Resources);
477var dashboard = Assert.Single(model.Resources);
516var container = Assert.Single(model.Resources, r => r.Name == "my-container");
520var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard");
562var container = Assert.Single(model.Resources, r => r.Name == "my-container");
566var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard");
610var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard");
642var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard");
844var dashboard = Assert.Single(model.Resources);
876static void SetDashboardAllocatedEndpoints(IResource dashboard, int otlpGrpcPort, int otlpHttpPort, int httpPort, int httpsPort)
Aspire.Hosting.TestUtilities (21)
Aspire.Hosting.Yarp (1)
Aspire.Playground.Tests (3)
Pipelines.Library (1)
Stress.AppHost (13)
TestResource.cs (9)
33public static IResourceBuilder<TestNestedResource> AddNestedResource(this IDistributedApplicationBuilder builder, string name, IResource parent)
52public static IResourceBuilder<CommandGroupResource> AddCommandGroup(this IDistributedApplicationBuilder builder, string name, IResource parent)
69public static IResourceBuilder<HttpCommandGroupResource> AddHttpCommandGroup(this IDistributedApplicationBuilder builder, string name, IResource parent)
211sealed class TestNestedResource(string name, IResource parent) : Resource(name), IResourceWithParent
213public IResource Parent { get; } = parent;
216sealed class CommandGroupResource(string name, IResource parent) : Resource(name), IResourceWithParent
218public IResource Parent { get; } = parent;
221sealed class HttpCommandGroupResource(string name, IResource parent) : Resource(name), IResourceWithParent, IResourceWithEndpoints
223public IResource Parent { get; } = parent;
Terminals.AppHost (3)