10 implementations of Name
Aspire.Hosting (1)
ApplicationModel\Resource.cs (1)
17public virtual string Name { get; }
Aspire.Hosting.Azure.EventHubs (1)
AzureEventHubsEmulatorResource.cs (1)
24public override string Name => _innerResource.Name;
Aspire.Hosting.Azure.PostgreSQL (1)
AzurePostgresResource.cs (1)
31public override string Name => _innerResource.Name;
Aspire.Hosting.Azure.Redis (1)
AzureRedisResource.cs (1)
31public override string Name => _innerResource.Name;
Aspire.Hosting.Azure.Storage (1)
AzureStorageEmulatorResource.cs (1)
17public override string Name => _innerResource.Name;
Aspire.Hosting.Tests (4)
DistributedApplicationBuilderTests.cs (1)
175public string Name => nameof(TestResource);
DistributedApplicationModelExtensionsTests.cs (1)
39public string Name { get; set; } = "CustomResource";
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
344public string Name { get; } = name;
Utils\VolumeNameGeneratorTests.cs (1)
46public string Name { get; } = name;
Aspire.Hosting.Yarp.Tests (1)
YarpClusterTests.cs (1)
81public string Name => name;
345 references to Name
Aspire.Hosting (129)
ApplicationModel\ConnectionStringReference.cs (1)
36internal void ThrowConnectionStringUnavailableException() => throw new DistributedApplicationException($"The connection string for the resource '{Resource.Name}' is not available.");
ApplicationModel\ContainerImageReference.cs (4)
22public string ValueExpression => $"{{{Resource.Name}.containerImage}}"; 30var deploymentTarget = Resource.GetDeploymentTargetAnnotation() ?? throw new InvalidOperationException($"Resource '{Resource.Name}' does not have a deployment target."); 31var containerRegistry = deploymentTarget.ContainerRegistry ?? throw new InvalidOperationException($"Resource '{Resource.Name}' does not have a container registry."); 36return $"{registryEndpoint}/{Resource.Name.ToLowerInvariant()}:{tag}";
ApplicationModel\ContainerPortReference.cs (1)
20public string ValueExpression => $"{{{Resource.Name}.containerPort}}";
ApplicationModel\CustomResourceSnapshot.cs (2)
428relationships.Add(new(resourceWithParent.Parent.Name, KnownRelationshipTypes.Parent)); 433relationships.Add(new(annotation.Resource.Name, annotation.Type));
ApplicationModel\EndpointReference.cs (3)
18internal EndpointAnnotation EndpointAnnotation => GetEndpointAnnotation() ?? throw new InvalidOperationException($"The endpoint `{EndpointName}` is not defined for the resource `{Resource.Name}`."); 62string Binding(string prop) => $"{{{Resource.Name}.bindings.{EndpointName}.{prop}}}"; 107?? throw new InvalidOperationException($"The endpoint `{EndpointName}` is not allocated for the resource `{Resource.Name}`.");
ApplicationModel\ExpressionResolver.cs (1)
20(EndpointProperty.Host or EndpointProperty.IPV4Host, true) => target.Name,
ApplicationModel\IResourceWithConnectionString.cs (1)
19string IManifestExpressionProvider.ValueExpression => $"{{{Name}.connectionString}}";
ApplicationModel\ResourceExtensions.cs (8)
446logger.LogInformation("Waiting for value from resource '{ResourceName}'", resource.Name); 450logger.LogInformation("Waiting for value for environment variable value '{Name}' from resource '{ResourceName}'", key, resource.Name); 455logger.LogInformation("Waiting for value for connection string from resource '{ResourceName}'", cs.Name); 627var computeEnvironmentNames = string.Join(", ", annotations.Select(a => a.ComputeEnvironment?.Name)); 628throw new InvalidOperationException($"Resource '{resource.Name}' has multiple compute environments - '{computeEnvironmentNames}'. Please specify a single compute environment using 'WithComputeEnvironment'."); 706throw new InvalidOperationException($"Resource '{resource.Name}' has no resolved names."); 710throw new InvalidOperationException($"Resource '{resource.Name}' has multiple resolved names: {string.Join(", ", names)}."); 729return [resource.Name];
ApplicationModel\ResourceNotificationService.cs (14)
131if (string.Equals(resourceName, resourceEvent.Resource.Name, StringComparisons.ResourceName) 152await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && re.Snapshot.HealthStatus == HealthStatus.Healthy, cancellationToken).ConfigureAwait(false); 157resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && re.Snapshot.ResourceReadyEvent is not null, cancellationToken: cancellationToken).ConfigureAwait(false); 260resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to complete.", dependency.Name); 266var displayName = names.Length > 1 ? names[i] : dependency.Name; 274var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsKnownTerminalState(re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 313resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to enter the '{State}' state.", dependency.Name, KnownResourceStates.Running); 321var displayName = names.Length > 1 ? names[i] : dependency.Name; 329var resourceEvent = await WaitForResourceCoreAsync(dependency.Name, re => re.ResourceId == resourceId && IsContinuableState(waitBehavior, re.Snapshot), cancellationToken: cancellationToken).ConfigureAwait(false); 452if (string.Equals(resourceName, resourceEvent.Resource.Name, StringComparisons.ResourceName) && predicate(resourceEvent)) 496foreach (var matchingResource in _resourceNotificationStates.Where(s => string.Equals(s.Value.Resource.Name, resourceId, StringComparisons.ResourceName))) 618_logger.LogDebug("Resource {ResourceName}/{ResourceId} changed state: {PreviousState} -> {NewState}", resource.Name, resourceId, previousStateText, newStateText); 623_logger.LogDebug("Resource {ResourceName}/{ResourceId} changed state: {NewState}", resource.Name, resourceId, newStateText); 647resource.Name,
Backchannel\AppHostRpcTarget.cs (3)
75if (resourceEvent.Resource.Name == "aspire-dashboard") 83logger.LogTrace("Resource {ResourceName} does not have endpoints.", resourceEvent.Resource.Name); 97Resource = resourceEvent.Resource.Name,
BuiltInDistributedApplicationEventSubscriptionHandlers.cs (1)
44if (beforeStartEvent.Model.Resources.SingleOrDefault(r => StringComparers.ResourceName.Equals(r.Name, KnownResourceNames.AspireDashboard)) is { } dashboardResource)
ConnectionStringBuilderExtensions.cs (2)
61if (resourceNames.Add(resource.Name)) 71if (resourceNames.Add(innerRef.Name))
Dashboard\DashboardLifecycleHook.cs (3)
65if (appModel.Resources.SingleOrDefault(r => StringComparers.ResourceName.Equals(r.Name, KnownResourceNames.AspireDashboard)) is { } dashboardResource) 643.Where(r => !string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)) 691if (StringComparers.ResourceName.Equals(notification.Resource.Name, KnownResourceNames.AspireDashboard) && !dashboardResourceTasks.ContainsKey(notification.ResourceId))
Dashboard\DashboardServiceData.cs (2)
49DisplayName = resource.Name, 84logger.LogError(ex, "Error updating resource snapshot for {Name}", @event.Resource.Name);
Dcp\DcpExecutor.cs (18)
122_resourceState = new(model.Resources.ToDictionary(r => r.Name), _appResources); 390_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 397_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 812if (allocatedResources.Add(resource.Name)) 903svc.Annotate(CustomResource.ResourceNameAnnotation, sp.ModelResource.Name); 1169resourceLogger.LogError(ex, "Failed to create resource {ResourceName}", er.ModelResource.Name); 1180resourceLogger.LogError(ex, "Failed to create resource {ResourceName}", resource.Name); 1353_ => throw new InvalidOperationException($"Unknown pull policy '{Enum.GetName(typeof(ImagePullPolicy), pullPolicy)}' for container '{container.Name}'") 1357ctr.Annotate(CustomResource.ResourceNameAnnotation, container.Name); 1358ctr.Annotate(CustomResource.OtelServiceNameAnnotation, container.Name); 1367Aliases = new List<string> { container.Name }, 1384throw new DistributedApplicationException($"Couldn't find required {nameof(DcpInstancesAnnotation)} annotation on resource {resource.Name}."); 1395throw new DistributedApplicationException($"Couldn't find required instance ID for index {instanceIndex} on resource {resource.Name}."); 1421logger.LogError(ex, "Failed to create container resource {ResourceName}", cr.ModelResource.Name); 1851_logger.LogError(ex, "Failed to start resource {ResourceName}", appResource.ModelResource.Name); 1925_logger.LogDebug(ex, "Failed to apply argument value '{ArgKey}' to '{ResourceName}'. A dependency may have failed to start.", ex.Data["ArgKey"], modelResource.Name); 1982_logger.LogDebug(ex, "Failed to apply environment variable '{Name}' to '{ResourceName}'. A dependency may have failed to start.", key, modelResource.Name); 2008_logger.LogDebug(ex, "Failed to apply argument value '{ArgKey}' to '{ResourceName}'. A dependency may have failed to start.", a, modelResource.Name);
Dcp\DcpNameGenerator.cs (1)
138return maybeWithSuffix(resource.Name, suffix, options.ResourceNameSuffix);
Devcontainers\DevcontainerPortForwardingLifecycleHook.cs (1)
58$"{resource.Name}-{endpoint.Name}");
DistributedApplicationBuilder.cs (5)
435missingResourceHealthCheck.Resource.Name); 537foreach (var duplicateResourceName in Resources.GroupBy(r => r.Name, StringComparers.ResourceName) 562if (Resources.FirstOrDefault(r => string.Equals(r.Name, resource.Name, StringComparisons.ResourceName)) is { } existingResource) 564throw new DistributedApplicationException($"Cannot add resource of type '{resource.GetType()}' with name '{resource.Name}' because resource of type '{existingResource.GetType()}' with that name already exists. Resource names are case-insensitive.");
DistributedApplicationBuilderExtensions.cs (1)
64var resource = builder.Resources.FirstOrDefault(r => string.Equals(r.Name, name, StringComparison.OrdinalIgnoreCase));
Exec\ExecResourceManager.cs (5)
97await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetState: KnownResourceStates.Running, cancellationToken).ConfigureAwait(false); 104await _resourceNotificationService.WaitForResourceAsync(execResource!.Name, targetStates: KnownResourceStates.TerminalStates, cancellationToken).ConfigureAwait(false); 165var targetResource = _model.Resources.FirstOrDefault(x => x.Name.Equals(_execOptions.ResourceName, StringComparisons.ResourceName)); 174_logger.LogDebug("Resource '{ResourceName}' has been successfully built and added to the model resources.", execResource.Name); 192_ => throw new InvalidOperationException($"Target resource {targetExecResource.Name} does not support exec mode.")
Health\ResourceHealthCheckService.cs (13)
31var resourceName = resourceEvent.Resource.Name; 115logger.LogDebug("Resource '{ResourceName}' has no health checks to monitor.", resource.Name); 122logger.LogDebug("Resource '{ResourceName}' health checks to monitor: {HeathCheckKeys}", resource.Name, string.Join(", ", registrationKeysToCheck)); 159logger.LogTrace("Health report status for '{ResourceName}' is {HealthReportStatus}.", resource.Name, report.Status); 179logger.LogTrace("Health reports for '{ResourceName}' have changed. Publishing updated reports.", resource.Name); 201resource.Name 213logger.LogTrace("Resource '{ResourceName}' health check monitoring loop starting delay of {DelayInterval}.", resource.Name, delayInterval); 242logger.LogDebug("Resource '{ResourceName}' is ready.", resource.Name); 249logger.LogDebug("Publishing ResourceReadyEvent for '{ResourceName}'.", resource.Name); 254logger.LogDebug("Waiting for ResourceReadyEvent for '{ResourceName}'.", resource.Name); 259logger.LogDebug("ResourceReadyEvent for '{ResourceName}' completed.", resource.Name); 261logger.LogDebug("Publishing the result of ResourceReadyEvent for '{ResourceName}'.", resource.Name); 315_resourceName = initialEvent.Resource.Name;
Orchestrator\ApplicationOrchestrator.cs (2)
93@event.Resource.Name, 263Logger = _loggerService.GetLogger(resource.Name)
ParameterResourceBuilderExtensions.cs (1)
273var parameter = new ParameterResource(builder.Resource.Name, _ => "", secret: true);
Publishing\ManifestPublishingContext.cs (3)
128Writer.WriteStartObject(resource.Name); 636_referencedResources.TryAdd(resource.Name, resource); 658_referencedResources.Remove(existingResource.Name);
Publishing\ResourceContainerImageBuilder.cs (6)
198logger.LogInformation("Building container image for resource {ResourceName}", resource.Name); 217resource.Name, 237$"Building image: {resource.Name}", 249await publishingTask.FailAsync($"Building image for {resource.Name} failed", cancellationToken).ConfigureAwait(false); 253await publishingTask.SucceedAsync($"Building image for {resource.Name} completed", cancellationToken).ConfigureAwait(false); 272var arguments = $"publish \"{projectMetadata.ProjectPath}\" --configuration Release /t:PublishContainer /p:ContainerRepository=\"{resource.Name}\"";
ResourceBuilderExtensions.cs (24)
413var serviceName = annotation.Resource.Name; 455connectionName ??= resource.Name; 1039context.Logger.LogWarning("Could not execute callback to customize endpoint URL as no endpoint with name '{EndpointName}' could be found on resource '{ResourceName}'.", endpointName, builder.Resource.Name); 1086context.Logger.LogWarning("Could not execute callback to add an endpoint URL as no endpoint with name '{EndpointName}' could be found on resource '{ResourceName}'.", endpointName, builder.Resource.Name); 1187throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1192throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1291throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1296throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1387throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for itself."); 1392throw new DistributedApplicationException($"The '{builder.Resource.Name}' resource cannot wait for its parent '{dependency.Resource.Name}'."); 1443throw new DistributedApplicationException($"Resource '{builder.Resource.Name}' already has a health check with key '{key}'."); 1525?? throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 1529throw new DistributedApplicationException($"Could not create HTTP health check for resource '{builder.Resource.Name}' as the endpoint with name '{endpoint.EndpointName}' and scheme '{endpoint.Scheme}' is not an HTTP endpoint."); 1541throw new DistributedApplicationException($"The endpoint '{endpointName}' does not exist on the resource '{builder.Resource.Name}'."); 1555var healthCheckKey = $"{builder.Resource.Name}_{endpointName}_{path}_{statusCode}_check"; 1877?? throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint selector returned null."); 1881throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as the endpoint with name '{endpoint.EndpointName}' and scheme '{endpoint.Scheme}' is not an HTTP endpoint."); 1889commandName ??= $"{endpoint.Resource.Name}-{endpoint.EndpointName}-http-{commandOptions.Method.Method.ToLowerInvariant()}-{path}"; 1989throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as the endpoint with name '{matchingEndpoint.EndpointName}' and scheme '{matchingEndpoint.Scheme}' is not an HTTP endpoint."); 1997throw new DistributedApplicationException($"Could not create {errorDisplayNoun} for resource '{builder.Resource.Name}' as no endpoint was found matching one of the specified names: {endpointNamesString}"); 2017throw new DistributedApplicationException($"Could not create HTTP command for resource '{builder.Resource.Name}' as it has no HTTP endpoints.");
ResourceLoggerForwarderService.cs (1)
66var logger = loggerFactory.CreateLogger($"{applicationName}.Resources.{resource.Name}");
Utils\ImageNameGenerator.cs (1)
16return builder.Resource.Name.ToLowerInvariant();
VolumeNameGenerator.cs (1)
33var resourceName = builder.Resource.Name;
Aspire.Hosting.Azure (25)
AzureDeployingContext.cs (11)
207var resourceTask = await computeStep.CreateTaskAsync($"Deploying {computeResource.Name}", cancellationToken).ConfigureAwait(false); 221var completionMessage = $"Successfully deployed {computeResource.Name}"; 232await resourceTask.CompleteAsync($"Skipped {computeResource.Name} - no Bicep deployment target", CompletionState.CompletedWithWarning, cancellationToken).ConfigureAwait(false); 237await resourceTask.CompleteAsync($"Skipped {computeResource.Name} - no deployment target annotation", CompletionState.Completed, cancellationToken).ConfigureAwait(false); 242await resourceTask.CompleteAsync($"Failed to deploy {computeResource.Name}: {ex.Message}", CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false); 356var localImageName = resource.Name.ToLowerInvariant(); 360var pushTask = await pushStep.CreateTaskAsync($"Pushing {resource.Name} to {registryName}", cancellationToken).ConfigureAwait(false); 367throw new InvalidOperationException($"Failed to get target tag for {resource.Name}"); 370await pushTask.CompleteAsync($"Successfully pushed {resource.Name} to {targetTag}", CompletionState.Completed, cancellationToken).ConfigureAwait(false); 374await pushTask.CompleteAsync($"Failed to push {resource.Name}: {ex.Message}", CompletionState.CompletedWithError, cancellationToken).ConfigureAwait(false); 409var endpoint = $"https://{computeResource.Name.ToLowerInvariant()}.{domainValue}";
AzurePublishingContext.cs (4)
314$"Processing deployment target {resource.Name}", 319var moduleDirectory = outputDirectory.CreateSubdirectory(resource.Name); 321var modulePath = Path.Combine(moduleDirectory.FullName, $"{resource.Name}.bicep"); 339$"Wrote bicep module for deployment target {resource.Name} to {modulePath}",
AzureResourceExtensions.cs (1)
33Infrastructure.NormalizeBicepIdentifier(resource.Name);
AzureResourcePreparer.cs (2)
279identityResource = new AzureUserAssignedIdentityResource($"{resource.Name}-identity") 300$"{resource.Name}-roles-{targetResource.Name}",
Provisioning\Provisioners\AzureProvisioner.cs (7)
210resourceLogger.LogInformation("Skipping {resourceName} because it is not a Bicep resource.", resource.AzureResource.Name); 217resourceLogger.LogInformation("Skipping {resourceName} because it is not configured to be provisioned.", resource.AzureResource.Name); 222resourceLogger.LogInformation("Using connection information stored in user secrets for {resourceName}.", resource.AzureResource.Name); 229resourceLogger.LogInformation("Resolving {resourceName} as existing resource...", resource.AzureResource.Name); 233resourceLogger.LogInformation("Provisioning {resourceName}...", resource.AzureResource.Name); 260resourceLogger.LogError(ex, "Error provisioning {ResourceName}.", resource.AzureResource.Name); 261resource.AzureResource.ProvisioningTaskCompletionSource?.TrySetException(new InvalidOperationException($"Unable to resolve references from {resource.AzureResource.Name}"));
Aspire.Hosting.Azure.AppContainers (13)
AzureContainerAppEnvironmentResource.cs (1)
77var outputName = $"{prefix}_{resource.Name}_{volumeIndex}";
AzureContainerAppExtensions.cs (2)
239$"{BicepFunction.ToLower(output.resource.Name)}-{BicepFunction.ToLower(volumeName)}"), 244$"{BicepFunction.ToLower(output.resource.Name)}-{BicepFunction.ToLower(volumeName)}"),
AzureContainerAppsInfrastructure.cs (1)
67throw new InvalidOperationException($"Resource '{r.Name}' is configured to publish as an Azure Container App, but there are no '{nameof(AzureContainerAppEnvironmentResource)}' resources. Ensure you have added one by calling '{nameof(AzureContainerAppExtensions.AddAzureContainerAppEnvironment)}'.");
BaseContainerAppContext.cs (1)
25public string NormalizedContainerAppName => resource.Name.ToLowerInvariant();
ContainerAppContext.cs (1)
101var containerApp = new ContainerApp(Infrastructure.NormalizeBicepIdentifier(Resource.Name))
ContainerAppEnvironmentContext.cs (3)
29throw new InvalidOperationException($"Container app context not found for resource {resource.Name}."); 43var provisioningResource = new AzureProvisioningResource(resource.Name, context.BuildContainerApp) 58throw new InvalidOperationException($"Resource '{resource.Name}' cannot have both AzureContainerAppCustomizationAnnotation and AzureContainerAppJobCustomizationAnnotation.");
ContainerAppJobContext.cs (1)
90var containerApp = new ContainerAppJob(Infrastructure.NormalizeBicepIdentifier(Resource.Name))
src\Shared\ResourceNameComparer.cs (3)
17return x.Name.Equals(y.Name, StringComparison.Ordinal); 21obj.Name.GetHashCode(StringComparison.Ordinal);
Aspire.Hosting.Azure.AppService (9)
AzureAppServiceEnvironmentContext.cs (2)
27throw new InvalidOperationException($"App Service context not found for resource {resource.Name}."); 41var provisioningResource = new AzureProvisioningResource(resource.Name, context.BuildWebSite)
AzureAppServiceInfrastructure.cs (1)
66throw new InvalidOperationException($"Resource '{r.Name}' is configured to publish as an Azure AppService Website, but there are no '{nameof(AzureAppServiceEnvironmentResource)}' resources. Ensure you have added one by calling '{nameof(AzureAppServiceEnvironmentExtensions.AddAzureAppServiceEnvironment)}'.");
AzureAppServiceWebsiteContext.cs (3)
37BicepFunction.Interpolate($"{BicepFunction.ToLower(resource.Name)}-{BicepFunction.GetUniqueString(BicepFunction.GetResourceGroup().Id)}"), 60); 88throw new NotSupportedException($"The endpoint(s) {string.Join(", ", unsupportedEndpoints.Select(e => $"'{e.Name}'"))} on resource '{resource.Name}' specifies an unsupported scheme. Only http and https are supported in App Service."); 95throw new NotSupportedException($"The endpoint '{endpoint.Name}' on resource '{resource.Name}' is not external. App Service only supports external endpoints.");
src\Shared\ResourceNameComparer.cs (3)
17return x.Name.Equals(y.Name, StringComparison.Ordinal); 21obj.Name.GetHashCode(StringComparison.Ordinal);
Aspire.Hosting.Azure.EventHubs (2)
AzureEventHubsExtensions.cs (2)
267context.EnvironmentVariables.Add("BLOB_SERVER", $"{blobEndpoint.Resource.Name}:{blobEndpoint.TargetPort}"); 268context.EnvironmentVariables.Add("METADATA_SERVER", $"{tableEndpoint.Resource.Name}:{tableEndpoint.TargetPort}");
Aspire.Hosting.Azure.Functions (1)
AzureFunctionsProjectResourceExtensions.cs (1)
245connectionName ??= source.Resource.Name;
Aspire.Hosting.Azure.Kusto (1)
AzureKustoBuilderExtensions.cs (1)
78if (builder.Resources.FirstOrDefault(n => string.Equals(n.Name, name, StringComparisons.ResourceName)) is AzureKustoDatabaseResource kustoDatabase)
Aspire.Hosting.Azure.ServiceBus (1)
AzureServiceBusExtensions.cs (1)
387context.EnvironmentVariables.Add("SQL_SERVER", $"{sqlEndpoint.Resource.Name}:{sqlEndpoint.TargetPort}");
Aspire.Hosting.Azure.Tests (21)
AzureContainerAppsTests.cs (3)
1699var funcjob = model.Resources.Single(r => r.Name == "funcjob"); 1743var batch = containers.First(c => c.Name == "batch"); 1744var web = containers.First(c => c.Name == "web");
AzureEventHubsExtensionsTests.cs (1)
517var azurite = builder.Resources.FirstOrDefault(x => x.Name == "eh-storage");
AzureFunctionsTests.cs (2)
29resource is AzureStorageResource && resource.Name.StartsWith(AzureFunctionsProjectResourceExtensions.DefaultAzureFunctionsHostStorageName)); 32resource is AzureFunctionsProjectResource && resource.Name == "funcapp");
AzureManifestUtils.cs (1)
29string manifestDir = Directory.CreateTempSubdirectory(resource.Name).FullName;
AzurePostgresExtensionsTests.cs (2)
289var postgresResourceInModel = builder.Resources.Single(r => r.Name == "postgres-data"); 290var dbResourceInModel = builder.Resources.Single(r => r.Name == "db1");
AzureRedisEnterpriseExtensionsTests.cs (1)
133var cacheInModel = builder.Resources.Single(r => r.Name == "cache");
AzureRedisExtensionsTests.cs (1)
176var cacheInModel = builder.Resources.Single(r => r.Name == "cache");
AzureServiceBusExtensionsTests.cs (1)
613var sql = builder.Resources.FirstOrDefault(x => x.Name == "sb-mssql");
AzureSqlExtensionsTests.cs (2)
217var sqlResourceInModel = builder.Resources.Single(r => r.Name == "sql"); 218var dbResourceInModel = builder.Resources.Single(r => r.Name == "db1");
AzureUserAssignedIdentityTests.cs (7)
73Assert.Collection(model.Resources.OrderBy(r => r.Name), 80Assert.Equal("myidentity-roles-myregistry", r.Name); 122var computeResource = Assert.Single(model.Resources.OfType<IComputeResource>(), r => r.Name == "myapp"); 168var computeResource = Assert.Single(model.Resources.OfType<IComputeResource>(), r => r.Name == "myapp"); 223var computeResource = Assert.Single(model.Resources.OfType<IComputeResource>(), r => r.Name == "myapp"); 301var computeResource = Assert.Single(model.Resources.OfType<IComputeResource>(), r => r.Name == "myapp"); 303var computeResource2 = Assert.Single(model.Resources.OfType<IComputeResource>(), r => r.Name == "myapp2");
Aspire.Hosting.Containers.Tests (5)
ContainerResourceTests.cs (5)
25Assert.Equal("container", containerResource.Name); 44Assert.Equal("container", containerResource.Name); 63Assert.Equal("container", containerResource.Name); 83Assert.Equal("container", containerResource.Name); 333Assert.Equal("containerwithbindmounts", containerResource.Name);
Aspire.Hosting.DevTunnels (16)
DevTunnelResourceBuilderExtensions.cs (13)
170portLogger.LogInformation("Created/updated dev tunnel port '{Port}' on tunnel '{Tunnel}' targeting endpoint '{Endpoint}' on resource '{TargetResource}'", portResource.TargetEndpoint.Port, portResource.DevTunnel.TunnelId, portResource.TargetEndpoint.EndpointName, portResource.TargetEndpoint.Resource.Name); 327var serviceName = targetResource.Resource.Name; 347throw new ArgumentException($"Target endpoint '{targetEndpoint.EndpointName}' on resource '{targetEndpoint.Resource.Name}' has already been added to dev tunnel '{tunnel.Name}'.", nameof(targetEndpoint)); 358throw new ArgumentException($"Cannot tunnel endpoint '{targetEndpointAnnotation.Name}' with host '{targetEndpointAnnotation.TargetHost}' on resource '{targetResource.Name}' because it is not a localhost endpoint.", nameof(targetEndpoint)); 370_ => throw new ArgumentException($"Cannot tunnel endpoint '{targetEndpoint.EndpointName}' on resource '{targetResource.Name}' because it uses the unsupported scheme '{targetEndpoint.Scheme}'. Only 'http' and 'https' endpoints can be tunneled."), 372portOptions.Description ??= $"{targetResource.Name}/{targetEndpoint.EndpointName}"; 374var portName = $"{tunnel.Name}-{targetResource.Name}-{targetEndpoint.EndpointName}"; 376portOptions.Labels.Add(targetResource.Name); 454new(CustomResourceKnownProperties.Source, $"{targetResource.Name}/{targetEndpoint.EndpointName}"), 455new("TargetResource", targetResource.Name), 483portLogger.LogError("Cannot tunnel endpoint '{Endpoint}' with host '{Host}' on resource '{Resource}' because it is not a localhost endpoint.", portResource.TargetEndpoint.EndpointName, portResource.TargetEndpoint.Host, portResource.TargetEndpoint.Resource.Name); 484portResource.TargetEndpointAllocatedTcs.SetException(new DistributedApplicationException($"Cannot tunnel endpoint '{portResource.TargetEndpoint.EndpointName}' with host '{portResource.TargetEndpoint.Host}' on resource '{portResource.TargetEndpoint.Resource.Name}' because it is not a localhost endpoint.")); 542portLogger.LogInformation("Forwarding from {PortUrl} to {TargetUrl} ({TargetResourceName}/{TargetEndpointName})", tunnelPortStatus.PortUri.ToString().TrimEnd('/'), portResource.TargetEndpoint.Url, portResource.TargetEndpoint.Resource.Name, portResource.TargetEndpoint.EndpointName);
src\Shared\ResourceNameComparer.cs (3)
17return x.Name.Equals(y.Name, StringComparison.Ordinal); 21obj.Name.GetHashCode(StringComparison.Ordinal);
Aspire.Hosting.Docker (16)
DockerComposeEnvironmentContext.cs (3)
19logger.LogInformation("Creating Docker Compose resource for {ResourceName}", resource.Name); 21var serviceResource = new DockerComposeServiceResource(resource.Name, resource, environment); 77serviceResource.TargetResource.Name,
DockerComposeInfrastructure.cs (2)
76throw new InvalidOperationException($"Resource '{r.Name}' is configured to publish as a Docker Compose service, but there are no '{nameof(DockerComposeEnvironmentResource)}' resources. Ensure you have added one by calling '{nameof(DockerComposeEnvironmentExtensions.AddDockerComposeEnvironment)}'."); 91context.EnvironmentVariables["OTEL_SERVICE_NAME"] = resource.Name;
DockerComposeServiceExtensions.cs (5)
110var imageEnvName = $"{resourceInstance.Name.ToUpperInvariant().Replace("-", "_")}_IMAGE"; 114description: $"Container image name for {resourceInstance.Name}", 115defaultValue: $"{resourceInstance.Name}:latest", 124var containerPortEnv = $"{resourceInstance.Name.ToUpperInvariant().Replace("-", "_")}_PORT"; 128description: $"Default container port for {resourceInstance.Name}",
DockerComposeServiceResource.cs (2)
76Name = resource.Name.ToLowerInvariant(), 137composeService.DependsOn[waitAnnotation.Resource.Name.ToLowerInvariant()] = new()
src\Shared\PublishingContextUtils.cs (1)
18return Path.Combine(context.OutputPath, environment.Name);
src\Shared\ResourceNameComparer.cs (3)
17return x.Name.Equals(y.Name, StringComparison.Ordinal); 21obj.Name.GetHashCode(StringComparison.Ordinal);
Aspire.Hosting.GitHub.Models.Tests (5)
GitHubModelsExtensionTests.cs (5)
265Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "github-gh-apikey")); 269Assert.Null(builder.Resources.FirstOrDefault(r => r.Name == "github-gh-apikey")); 270Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key1")); 274Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key1")); 275Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key2"));
Aspire.Hosting.Kafka (2)
KafkaBuilderExtensions.cs (2)
140? ReferenceExpression.Create($"{endpoint.Resource.Name}:{endpoint.Property(EndpointProperty.TargetPort)}") 143context.EnvironmentVariables.Add($"KAFKA_CLUSTERS_{index}_NAME", endpoint.Resource.Name);
Aspire.Hosting.Kafka.Tests (1)
AddKafkaTests.cs (1)
173var kafkaUiResource = Assert.Single(builder.Resources, r => r.Name == expectedContainerName);
Aspire.Hosting.Keycloak.Tests (2)
KeycloakPublicApiTests.cs (2)
163var keycloakResource = builder.Resources.Single(r => r.Name.Equals(resourceName, StringComparison.Ordinal)); 190var keycloakResource = builder.Resources.Single(r => r.Name.Equals(resourceName, StringComparison.Ordinal));
Aspire.Hosting.Kubernetes (32)
Extensions\ResourceExtensions.cs (10)
17Name = resource.Name.ToDeploymentName(), 46Name = resource.Name.ToStatefulSetName(), 71Name = resource.Name.ToSecretName(), 102Name = resource.Name.ToConfigMapName(), 129Name = resource.Name.ToServiceName(), 225Name = resource.Name, 321Name = context.TargetResource.Name.ToConfigMapName(), 338Name = context.TargetResource.Name.ToSecretName(), 348var pvName = context.TargetResource.Name.ToPvName(volume.Name); 392var pvcName = context.TargetResource.Name.ToPvcName(volume.Name);
KubernetesEnvironmentContext.cs (2)
22logger.LogInformation("Creating Kubernetes resource for {ResourceName}", resource.Name); 24var serviceResource = new KubernetesResource(resource.Name, resource, environment);
KubernetesInfrastructure.cs (1)
60throw new InvalidOperationException($"Resource '{r.Name}' is configured to publish as a Kubernetes service, but there are no '{nameof(KubernetesEnvironmentResource)}' resources. Ensure you have added one by calling '{nameof(KubernetesEnvironmentExtensions.AddKubernetesEnvironment)}'.");
KubernetesPublishingContext.cs (3)
134helmSection[resource.Name.ToHelmValuesSectionName()] = paramValues; 140var templatesFolder = Path.Combine(OutputPath, "templates", resource.Name); 145var fileName = GetFilename(resource.Name, templatedItem);
KubernetesResource.cs (11)
114["app.kubernetes.io/component"] = resource.Name, 140var imageEnvName = $"{resourceInstance.Name.ToHelmValuesSectionName()}_image"; 141var value = $"{resourceInstance.Name}:latest"; 142var expression = imageEnvName.ToHelmParameterExpression(resource.Name); 174var port = endpoint.TargetPort ?? throw new InvalidOperationException($"Unable to resolve port {endpoint.TargetPort} for endpoint {endpoint.Name} on resource {resource.Name}"); 176EndpointMappings[endpoint.Name] = new(endpoint.UriScheme, resource.Name.ToServiceName(), portValue, endpoint.Name); 186var helmExpression = paramName.ToHelmParameterExpression(resource.Name); 189var aspNetCoreUrlsExpression = "ASPNETCORE_URLS".ToHelmConfigExpression(resource.Name); 192EndpointMappings[endpoint.Name] = new(endpoint.UriScheme, resource.Name.ToServiceName(), helmExpression, endpoint.Name, helmExpression); 272ProcessEnvironmentStringValue(stringValue, key, resource.Name); 275ProcessEnvironmentDefaultValue(value, key, resource.Name);
KubernetesServiceResourceExtensions.cs (4)
122formattedName.ToHelmSecretExpression(resource.Name) : 123formattedName.ToHelmConfigExpression(resource.Name); 144formattedName.ToHelmSecretExpression(resource.Name) : 145formattedName.ToHelmConfigExpression(resource.Name);
src\Shared\PublishingContextUtils.cs (1)
18return Path.Combine(context.OutputPath, environment.Name);
Aspire.Hosting.Milvus.Tests (2)
AddMilvusTests.cs (2)
28Assert.Equal("my-milvus", containerResource.Name); 58Assert.Equal("my-milvus", containerResource.Name);
Aspire.Hosting.MySql (2)
MySqlBuilderExtensions.cs (2)
254context.EnvironmentVariables.Add("PMA_HOST", $"{endpoint.Resource.Name}:{endpoint.TargetPort}"); 394writer.WriteLine($"$cfg['Servers'][$i]['host'] = '{endpoint.Resource.Name}:{endpoint.TargetPort}';");
Aspire.Hosting.MySql.Tests (4)
AddMySqlTests.cs (4)
85Assert.Equal("mysql", containerResource.Name); 241var myAdmin = builder.Resources.Single(r => r.Name.Equals("phpmyadmin")); 247var container = builder.Resources.Single(r => r.Name == "phpmyadmin"); 273var myAdmin = builder.Resources.Single(r => r.Name.Equals("phpmyadmin"));
Aspire.Hosting.OpenAI.Tests (5)
OpenAIExtensionTests.cs (5)
209Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "openai-openai-apikey")); 214Assert.Null(builder.Resources.FirstOrDefault(r => r.Name == "openai-openai-apikey")); 215Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key1")); 219Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key1")); 220Assert.NotNull(builder.Resources.FirstOrDefault(r => r.Name == "secret-key2"));
Aspire.Hosting.Oracle.Tests (3)
AddOracleTests.cs (3)
45Assert.Equal("orcl", containerResource.Name); 84Assert.Equal("orcl", containerResource.Name); 166Assert.Equal("oracle", containerResource.Name);
Aspire.Hosting.Orleans (4)
OrleansServiceExtensions.cs (3)
131=> WithGrainStorage(orleansServiceBuilder, provider.Resource.Name, provider); 183=> WithStreaming(orleansServiceBuilder, provider.Resource.Name, provider); 299=> WithGrainDirectory(orleansServiceBuilder, provider.Resource.Name, provider);
ProviderConfiguration.cs (1)
21var serviceKey = resourceBuilder.Resource.Name;
Aspire.Hosting.PostgreSQL (2)
PostgresBuilderExtensions.cs (2)
85if (builder.Resources.FirstOrDefault(n => string.Equals(n.Name, name, StringComparisons.ResourceName)) is PostgresDatabaseResource postgreDatabase) 547writer.WriteString("Host", endpoint.Resource.Name);
Aspire.Hosting.PostgreSQL.Tests (8)
AddPostgresTests.cs (8)
55Assert.Equal("myPostgres", containerResource.Name); 109Assert.Equal("myPostgres", containerResource.Name); 202Assert.Equal("postgres", containerResource.Name); 381var container = builder.Resources.Single(r => r.Name == "pgadmin"); 435var container = builder.Resources.Single(r => r.Name == "pgadmin"); 448Assert.Single(builder.Resources, r => r.Name.Equals("pgadmin")); 469var pgadmin = builder.Resources.Single(r => r.Name.Equals("pgadmin")); 534var pgweb = builder.Resources.Single(r => r.Name.Equals("pgweb"));
Aspire.Hosting.Qdrant.Tests (4)
AddQdrantTests.cs (3)
48Assert.Equal("my-qdrant", containerResource.Name); 87Assert.Equal("my-qdrant", containerResource.Name); 120Assert.Equal("my-qdrant", containerResource.Name);
QdrantFunctionalTests.cs (1)
229var qdrantResource = builder.Resources.Single(r => r.Name.Equals("qdrant"));
Aspire.Hosting.Redis.Tests (4)
AddRedisTests.cs (4)
284var redisinsight = builder.Resources.Single(r => r.Name.Equals("redisinsight")); 494var commander = builder.Resources.Single(r => r.Name.Equals("rediscommander")); 520var commander = builder.Resources.Single(r => r.Name.Equals("rediscommander")); 541var commander = builder.Resources.Single(r => r.Name.Equals("rediscommander"));
Aspire.Hosting.Testing (1)
DistributedApplicationHostingTestingExtensions.cs (1)
80var resource = resources.SingleOrDefault(r => string.Equals(r.Name, resourceName, StringComparison.OrdinalIgnoreCase));
Aspire.Hosting.Testing.Tests (2)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (2)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken); 134if (resourceName != null && !string.Equals(resourceEvent.Resource.Name, resourceName, StringComparison.OrdinalIgnoreCase))
Aspire.Hosting.Tests (13)
Dashboard\DashboardLifecycleHookTests.cs (3)
90var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)); 138var dashboardResource = model.Resources.Single(r => string.Equals(r.Name, KnownResourceNames.AspireDashboard, StringComparisons.ResourceName)); 235Assert.Equal(KnownResourceNames.AspireDashboard, dashboardResource.Name);
Dashboard\DashboardResourceTests.cs (5)
76r => Assert.Equal("aspire-dashboard", r.Name), 77r => Assert.Equal("my-container", r.Name) 337var container = Assert.Single(model.Resources, r => r.Name == "my-container"); 341var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard"); 382var dashboard = Assert.Single(model.Resources, r => r.Name == "aspire-dashboard");
PublishingTests.cs (1)
161Assert.Equal("cache", context.Model.Resources.Single().Name);
Utils\LoggerNotificationExtensions.cs (2)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken); 134if (resourceName != null && !string.Equals(resourceEvent.Resource.Name, resourceName, StringComparison.OrdinalIgnoreCase))
Utils\ManifestUtils.cs (2)
34var resourceNode = obj[resource.Name]; 56var resourceNode = obj[r.Name];
Aspire.Hosting.Yarp (4)
ConfigurationBuilder\YarpCluster.cs (4)
27: this(endpoint.Resource.Name, $"{endpoint.Scheme}://_{endpoint.EndpointName}.{endpoint.Resource.Name}") 36: this(resource.Name, BuildEndpointUri(resource)) 70var resourceName = resource.Name;
Aspire.Playground.Tests (4)
Infrastructure\DistributedApplicationExtensions.cs (2)
106return Task.WhenAll(applicationModel.Resources.Select(r => app.ResourceNotifications.WaitForResourceAsync(r.Name, r => targetStates?.Contains(r.Snapshot.State?.Text, StringComparer.OrdinalIgnoreCase) is true || r.Snapshot.IsHidden, cancellationToken))); 134var assertableResourceLogNames = applicationModel.Resources.Where(ShouldAssertErrorsForResource).Select(r => $"{environment.ApplicationName}.Resources.{r.Name}").ToList();
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (2)
36await rns.WaitForResourceHealthyAsync(resource.Resource.Name, cancellationToken); 134if (resourceName != null && !string.Equals(resourceEvent.Resource.Name, resourceName, StringComparison.OrdinalIgnoreCase))
Stress.AppHost (2)
Program.cs (1)
159.Where(r => r.Name != KnownResourceNames.AspireDashboard)
TestResource.cs (1)
40new(KnownProperties.Resource.ParentName, parent.Name)