2 writes to Resource
Aspire.Hosting (2)
ApplicationModel\EndpointReference.cs (2)
141Resource = owner; 156Resource = owner;
51 references to Resource
Aspire.Hosting (10)
ApplicationModel\EndpointReference.cs (5)
22public EndpointAnnotation EndpointAnnotation => GetEndpointAnnotation() ?? throw new InvalidOperationException(ErrorMessage ?? $"The endpoint `{EndpointName}` is not defined for the resource `{Resource.Name}`."); 29IEnumerable<object> IValueWithReferences.References => [Resource]; 76string Binding(string prop) => $"{{{Resource.Name}.bindings.{EndpointName}.{prop}}}"; 124?? throw new InvalidOperationException($"The endpoint `{EndpointName}` is not allocated for the resource `{Resource.Name}`."); 127_endpointAnnotation ??= Resource.Annotations.OfType<EndpointAnnotation>().SingleOrDefault(a => StringComparers.EndpointAnnotationName.Equals(a.Name, EndpointName));
ApplicationModel\ExpressionResolver.cs (1)
16var target = endpointReference.Resource.GetRootResource();
ResourceBuilderExtensions.cs (4)
150builder.WithReferenceRelationship(endpointReference.Resource); 703ApplyEndpoints(builder, endpointReference.Resource, endpointReference.EndpointName); 2080commandName ??= $"{endpoint.Resource.Name}-{endpoint.EndpointName}-http-{commandOptions.Method.Method.ToLowerInvariant()}-{path}"; 2092if (resourceEvent.Resource == endpoint.Resource)
Aspire.Hosting.Azure (1)
AzureBicepResourceExtensions.cs (1)
306builder.WithReferenceRelationship(value.Resource);
Aspire.Hosting.Azure.AppContainers (5)
AzureContainerAppEnvironmentResource.cs (1)
198var resource = endpointReference.Resource;
BaseContainerAppContext.cs (4)
224var context = ep.Resource == resource 226: _containerAppEnvironmentContext.GetContainerAppContext(ep.Resource); 276var context = epExpr.Endpoint.Resource == resource 278: _containerAppEnvironmentContext.GetContainerAppContext(epExpr.Endpoint.Resource);
Aspire.Hosting.Azure.AppService (3)
AzureAppServiceEnvironmentResource.cs (1)
226var resource = endpointReference.Resource;
AzureAppServiceWebsiteContext.cs (2)
138var context = environmentContext.GetAppServiceContext(ep.Resource); 175var context = environmentContext.GetAppServiceContext(epExpr.Endpoint.Resource);
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.ServiceBus (1)
AzureServiceBusExtensions.cs (1)
387context.EnvironmentVariables.Add("SQL_SERVER", $"{sqlEndpoint.Resource.Name}:{sqlEndpoint.TargetPort}");
Aspire.Hosting.DevTunnels (11)
DevTunnelResource.cs (1)
69TunnelEndpoint = new(targetEndpoint.Resource, TunnelEndpointAnnotation);
DevTunnelResourceBuilderExtensions.cs (10)
194portLogger.LogInformation("Created 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); 356.FirstOrDefault(p => p.TargetEndpoint.Resource == resource && StringComparers.EndpointAnnotationName.Equals(p.TargetEndpoint.EndpointName, endpointName)); 378.FirstOrDefault(p => p.TargetEndpoint.Resource == targetEndpointReference.Resource 383return CreateEndpointReferenceWithError(tunnelBuilder.Resource, targetEndpointReference.Resource, targetEndpointReference.EndpointName); 432foreach (var port in tunnelResource.Resource.Ports.Where(p => p.TargetEndpoint.Resource == targetResource.Resource)) 458var targetResource = targetEndpoint.Resource; 463throw new ArgumentException($"Target endpoint '{targetEndpoint.EndpointName}' on resource '{targetEndpoint.Resource.Name}' has already been added to dev tunnel '{tunnel.Name}'.", nameof(targetEndpoint)); 466if (targetEndpoint.Resource.Annotations.OfType<EndpointAnnotation>() 647portLogger.LogInformation("Forwarding from {PortUrl} to {TargetUrl} ({TargetResourceName}/{TargetEndpointName})", tunnelPortStatus.PortUri.ToString().TrimEnd('/'), portResource.TargetEndpoint.Url, portResource.TargetEndpoint.Resource.Name, portResource.TargetEndpoint.EndpointName);
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
83Assert.Equal(target.Resource, tunnelEndpoint.Resource); 100Assert.Equal(target.Resource, tunnelEndpoint.Resource); 118Assert.Equal(target.Resource, tunnelEndpoint.Resource);
Aspire.Hosting.Docker (3)
DockerComposeEnvironmentResource.cs (1)
81var resource = endpointReference.Resource;
DockerComposeServiceResourceExtensions.cs (2)
22var referencedResource = resource.Parent.ResourceMapping[ep.Resource]; 50var referencedResource = resource.Parent.ResourceMapping[epExpr.Endpoint.Resource];
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.Kubernetes (5)
KubernetesEnvironmentResource.cs (1)
107var resource = endpointReference.Resource;
KubernetesResource.cs (4)
368var referencedResource = ep.Resource == this 370: await context.CreateKubernetesResourceAsync(ep.Resource, executionContext, default).ConfigureAwait(false); 398var referencedResource = epExpr.Endpoint.Resource == this 400: await context.CreateKubernetesResourceAsync(epExpr.Endpoint.Resource, executionContext, default).ConfigureAwait(false);
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.PostgreSQL (1)
PostgresBuilderExtensions.cs (1)
547writer.WriteString("Host", endpoint.Resource.Name);
Aspire.Hosting.Yarp (2)
ConfigurationBuilder\YarpCluster.cs (2)
26: this(endpoint.Resource.Name, $"{endpoint.Scheme}://_{endpoint.EndpointName}.{endpoint.Resource.Name}")