EndpointReference

ApplicationModel\ResourceExtensions.cs (2)

508return endpoints.Select(e => new EndpointReference(resource, e)); 523return new EndpointReference(resource, endpointName);

Orchestrator\ApplicationOrchestrator.cs (1)

194var url = new ResourceUrlAnnotation { Url = allocatedEndpoint.UriString, Endpoint = new EndpointReference(resourceWithEndpoints, endpoint) };

ResourceBuilderExtensions.cs (1)

595var endpointReference = new EndpointReference(resourceWithEndpoints, annotation);

AzureCosmosDBResource.cs (1)

25internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureEventHubsResource.cs (1)

41internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureServiceBusResource.cs (1)

31internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureSignalRResource.cs (1)

18internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureStorageResource.cs (3)

22private EndpointReference EmulatorBlobEndpoint => new(this, "blob"); 23private EndpointReference EmulatorQueueEndpoint => new(this, "queue"); 24private EndpointReference EmulatorTableEndpoint => new(this, "table");

AzureStorageExtensionsTests.cs (1)

313=> new(storage.Resource, new EndpointAnnotation(ProtocolType.Tcp, name: name, targetPort: port));

DockerComposeAspireDashboardResource.cs (2)

18public EndpointReference PrimaryEndpoint => new(this, "http"); 23public EndpointReference OtlpGrpcEndpoint => new(this, "otlp-grpc");

GarnetResource.cs (1)

29public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

KafkaServerResource.cs (2)

26public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName); 32public EndpointReference InternalEndpoint => _internalEndpoint ??= new(this, InternalEndpointName);

MilvusServerResource.cs (1)

36public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

MongoDBServerResource.cs (1)

34public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

MySqlServerResource.cs (1)

25PrimaryEndpoint = new(this, PrimaryEndpointName);

NatsServerResource.cs (1)

33public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

OracleDatabaseServerResource.cs (1)

22PrimaryEndpoint = new(this, PrimaryEndpointName);

PgWebContainerResource.cs (1)

21public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

PostgresServerResource.cs (1)

24PrimaryEndpoint = new(this, PrimaryEndpointName);

QdrantServerResource.cs (2)

36public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName); 41public EndpointReference HttpEndpoint => _httpEndpoint ??= new(this, HttpEndpointName);

RabbitMQServerResource.cs (1)

25PrimaryEndpoint = new(this, PrimaryEndpointName);

RedisInsightResource.cs (1)

21public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

RedisResource.cs (1)

32public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

SeqResource.cs (1)

19public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

SqlServerServerResource.cs (1)

22PrimaryEndpoint = new(this, PrimaryEndpointName);

ExpressionResolverTests.cs (3)

194PrimaryEndpoint = new(this, "http"); 214EndpointReference Endpoint1 => new(this, "endpoint1"); 215EndpointReference Endpoint2 => new(this, "endpoint2");

ValkeyResource.cs (1)

34public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

ApplicationModel\EndpointReference.cs (5)

115/// Creates a new instance of <see cref="EndpointReference"/> with the specified endpoint name. 130/// Creates a new instance of <see cref="EndpointReference"/> with the specified endpoint name. 149public class EndpointReferenceExpression(EndpointReference endpointReference, EndpointProperty property) : IManifestExpressionProvider, IValueProvider, IValueWithReferences 152/// Gets the <see cref="EndpointReference"/>. 154public EndpointReference Endpoint { get; } = endpointReference ?? throw new ArgumentNullException(nameof(endpointReference));

ApplicationModel\ExpressionResolver.cs (3)

19static string EndpointUniqueName(EndpointReference endpointReference) => $"{endpointReference.Resource.Name}/{endpointReference.EndpointName}"; 25async Task<string?> EvalEndpointAsync(EndpointReference endpointReference, EndpointProperty property) 181EndpointReference endpointReference when sourceIsContainer => new ResolvedValue(await EvalEndpointAsync(endpointReference, EndpointProperty.Url).ConfigureAwait(false), false),

ApplicationModel\HttpCommandContext.cs (4)

9/// or <see cref="ResourceBuilderExtensions.WithHttpCommand{TResource}(IResourceBuilder{TResource}, string, string, Func{EndpointReference}?, string?, HttpCommandOptions?)"/>. 26public required EndpointReference Endpoint { get; init; } 47/// or <see cref="ResourceBuilderExtensions.WithHttpCommand{TResource}(IResourceBuilder{TResource}, string, string, Func{EndpointReference}?, string?, HttpCommandOptions?)"/>. 64public required EndpointReference Endpoint { get; init; }

ApplicationModel\HttpCommandOptions.cs (1)

16public Func<EndpointReference>? EndpointSelector { get; set; }

ApplicationModel\ProjectResource.cs (1)

25internal bool ShouldInjectEndpointEnvironment(EndpointReference e)

ApplicationModel\ResourceExtensions.cs (4)

503/// <returns>An enumeration of <see cref="EndpointReference"/> based on the <see cref="EndpointAnnotation"/> annotations from the resources' <see cref="IResource.Annotations"/> collection.</returns> 504public static IEnumerable<EndpointReference> GetEndpoints(this IResourceWithEndpoints resource) 519/// <returns>An <see cref="EndpointReference"/> object representing the endpoint reference 521public static EndpointReference GetEndpoint(this IResourceWithEndpoints resource, string endpointName)

ApplicationModel\ResourceUrlAnnotation.cs (2)

27public EndpointReference? Endpoint { get; init; } 41internal ResourceUrlAnnotation WithEndpoint(EndpointReference endpoint)

ApplicationModel\ResourceUrlsCallbackContext.cs (1)

29public EndpointReference? GetEndpoint(string name) =>

ProjectResourceBuilderExtensions.cs (3)

746foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 798foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment)) 829foreach (var e in builder.Resource.GetEndpoints().Where(builder.Resource.ShouldInjectEndpointEnvironment))

ResourceBuilderExtensions.cs (21)

143public static IResourceBuilder<T> WithEnvironment<T>(this IResourceBuilder<T> builder, string name, EndpointReference endpointReference) where T : IResourceWithEnvironment 342foreach (var endpoint in annotation.Resource.GetEndpoints()) 450public static IResourceBuilder<TDestination> WithReference<TDestination>(this IResourceBuilder<TDestination> builder, EndpointReference endpointReference) 595var endpointReference = new EndpointReference(resourceWithEndpoints, annotation); 693/// Gets an <see cref="EndpointReference"/> by name from the resource. These endpoints are declared either using <see cref="WithEndpoint{T}(IResourceBuilder{T}, int?, int?, string?, string?, string?, bool, bool?, ProtocolType?)"/> or by launch settings (for project resources). 694/// The <see cref="EndpointReference"/> can be used to resolve the address of the endpoint in <see cref="WithEnvironment{T}(IResourceBuilder{T}, Action{EnvironmentCallbackContext})"/>. 699/// <returns>An <see cref="EndpointReference"/> that can be used to resolve the address of the endpoint after resource allocation has occurred.</returns> 700public static EndpointReference GetEndpoint<T>(this IResourceBuilder<T> builder, [EndpointName] string name) where T : IResourceWithEndpoints 862var endpoint = url.ValueProviders.OfType<EndpointReference>().FirstOrDefault(); 882/// To add another URL for an endpoint, use <see cref="WithUrlForEndpoint{T}(IResourceBuilder{T}, string, Func{EndpointReference, ResourceUrlAnnotation})"/>. 955public static IResourceBuilder<T> WithUrlForEndpoint<T>(this IResourceBuilder<T> builder, string endpointName, Func<EndpointReference, ResourceUrlAnnotation> callback) 960var endpoint = builder.GetEndpoint(endpointName); 1298public static IResourceBuilder<T> WithHttpHealthCheck<T>(this IResourceBuilder<T> builder, Func<EndpointReference>? endpointSelector, string? path = null, int? statusCode = null) where T : IResourceWithEndpoints 1302var endpoint = endpointSelector() 1647Func<EndpointReference>? endpointSelector, 1654var endpoint = endpointSelector() 1752private static Func<EndpointReference> NamedEndpointSelector<TResource>(IResourceBuilder<TResource> builder, string[] endpointNames, string errorDisplayNoun) 1758EndpointReference? matchingEndpoint = null; 1778private static Func<EndpointReference> DefaultEndpointSelector<TResource>(IResourceBuilder<TResource> builder) 1784EndpointReference? matchingEndpoint = null;

AzureBicepResourceExtensions.cs (1)

301public static IResourceBuilder<T> WithParameter<T>(this IResourceBuilder<T> builder, string name, EndpointReference value)

AzureProvisioningResourceExtensions.cs (4)

205/// The <see cref="EndpointReference"/> to use for the value of the <see cref="ProvisioningParameter"/>. 213/// This is useful when assigning a <see cref="BicepValue"/> to the value of an Aspire <see cref="EndpointReference"/>. 215public static ProvisioningParameter AsProvisioningParameter(this EndpointReference endpointReference, AzureResourceInfrastructure infrastructure, string parameterName) 239/// This is useful when assigning a <see cref="BicepValue"/> to the value of an Aspire <see cref="EndpointReference"/>.

AzureResourcePreparer.cs (1)

395if (value is string or EndpointReference or ParameterResource or EndpointReferenceExpression or HostUrl)

ContainerAppContext.cs (1)

490if (value is EndpointReference ep)

AzureAppServiceWebsiteContext.cs (1)

115if (value is EndpointReference ep)

AzureCosmosDBEmulatorConnectionString.cs (1)

11public static ReferenceExpression Create(EndpointReference endpoint, bool isPreviewEmulator) =>

AzureCosmosDBResource.cs (1)

25internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureEventHubsExtensions.cs (2)

259var blobEndpoint = storage.GetEndpoint("blob"); 260var tableEndpoint = storage.GetEndpoint("table");

AzureEventHubsResource.cs (1)

41internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureFunctionsProjectResourceExtensions.cs (2)

108var endpoint = resource.GetEndpoint("http"); 194var targetEndpoint = builder.Resource.GetEndpoint(useHttps ? "https" : "http");

AzureServiceBusExtensions.cs (1)

381var sqlEndpoint = sqlEdgeResource.Resource.GetEndpoint("tcp");

AzureServiceBusResource.cs (1)

31internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureSignalRResource.cs (1)

18internal EndpointReference EmulatorEndpoint => new(this, "emulator");

AzureStorageEmulatorConnectionString.cs (4)

13public static ReferenceExpression Create(EndpointReference? blobEndpoint = null, EndpointReference? queueEndpoint = null, EndpointReference? tableEndpoint = null) 33static void AppendEndpointExpression(ReferenceExpressionBuilder builder, string key, EndpointReference endpoint)

AzureStorageResource.cs (3)

22private EndpointReference EmulatorBlobEndpoint => new(this, "blob"); 23private EndpointReference EmulatorQueueEndpoint => new(this, "queue"); 24private EndpointReference EmulatorTableEndpoint => new(this, "table");

AzureContainerAppsTests.cs (6)

300var httpEp = project.GetEndpoint("http"); 301var httpsEp = project.GetEndpoint("https"); 302var internalEp = project.GetEndpoint("internal"); 377var httpEp = project.GetEndpoint("http"); 378var httpsEp = project.GetEndpoint("https"); 379var internalEp = project.GetEndpoint("internal");

AzureCosmosDBExtensionsTests.cs (1)

84var endpoint = cosmos.GetEndpoint("data-explorer");

AzureProvisioningResourceExtensionsTests.cs (1)

20var endpointReference = apiProject.GetEndpoint("https");

AzureStorageExtensionsTests.cs (1)

312EndpointReference GetEndpointReference(string name, int port)

src\Aspire.Hosting.Azure.Storage\AzureStorageEmulatorConnectionString.cs (4)

13public static ReferenceExpression Create(EndpointReference? blobEndpoint = null, EndpointReference? queueEndpoint = null, EndpointReference? tableEndpoint = null) 33static void AppendEndpointExpression(ReferenceExpressionBuilder builder, string key, EndpointReference endpoint)

DockerComposeAspireDashboardResource.cs (2)

18public EndpointReference PrimaryEndpoint => new(this, "http"); 23public EndpointReference OtlpGrpcEndpoint => new(this, "otlp-grpc");

DockerComposeEnvironmentContext.cs (1)

133.Where(kvp => kvp.Value is EndpointReference epRef && epRef.Scheme == "https" && kvp.Key.StartsWith("services__"))

DockerComposeInfrastructure.cs (2)

68if (environment.DashboardEnabled && environment.Dashboard?.Resource.OtlpGrpcEndpoint is EndpointReference otlpGrpcEndpoint) 84private static void ConfigureOtlp(IResource resource, EndpointReference otlpEndpoint)

DockerComposeServiceResourceExtensions.cs (1)

20if (value is EndpointReference ep)

GarnetResource.cs (2)

24private EndpointReference? _primaryEndpoint; 29public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

KafkaBuilderExtensions.cs (4)

121var endpoint = kafkaResource.InternalEndpoint; 137static void ConfigureKafkaUIContainer(EnvironmentCallbackContext context, EndpointReference endpoint, int index) 213var primaryEndpoint = resource.PrimaryEndpoint; 215var internalEndpoint = resource.InternalEndpoint;

KafkaServerResource.cs (4)

19private EndpointReference? _primaryEndpoint; 20private EndpointReference? _internalEndpoint; 26public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName); 32public EndpointReference InternalEndpoint => _internalEndpoint ??= new(this, InternalEndpointName);

KubernetesServiceResourceExtensions.cs (1)

22if (value is EndpointReference ep)

MilvusServerResource.cs (2)

26private EndpointReference? _primaryEndpoint; 36public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

MongoDBServerResource.cs (2)

17private EndpointReference? _primaryEndpoint; 34public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

MySqlBuilderExtensions.cs (2)

221var endpoint = singleInstance.PrimaryEndpoint; 362var endpoint = mySqlInstance.PrimaryEndpoint;

MySqlServerResource.cs (1)

32public EndpointReference PrimaryEndpoint { get; }

NatsServerResource.cs (2)

16private EndpointReference? _primaryEndpoint; 33public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

OracleDatabaseServerResource.cs (1)

29public EndpointReference PrimaryEndpoint { get; }

PgWebContainerResource.cs (2)

16private EndpointReference? _primaryEndpoint; 21public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

PostgresBuilderExtensions.cs (1)

533var endpoint = postgresInstance.PrimaryEndpoint;

PostgresServerResource.cs (1)

32public EndpointReference PrimaryEndpoint { get; }

QdrantServerResource.cs (4)

25private EndpointReference? _primaryEndpoint; 26private EndpointReference? _httpEndpoint; 36public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName); 41public EndpointReference HttpEndpoint => _httpEndpoint ??= new(this, HttpEndpointName);

RabbitMQServerResource.cs (1)

33public EndpointReference PrimaryEndpoint { get; }

RedisInsightResource.cs (2)

16private EndpointReference? _primaryEndpoint; 21public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

RedisResource.cs (2)

27private EndpointReference? _primaryEndpoint; 32public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

RedisFunctionalTests.cs (2)

85var endpoint = redis.GetEndpoint("tcp"); 619var endpoint = redisCommander.GetEndpoint("http");

SeqResource.cs (2)

14private EndpointReference? _primaryEndpoint; 19public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

SqlServerServerResource.cs (1)

29public EndpointReference PrimaryEndpoint { get; }

DistributedApplicationHostingTestingExtensions.cs (3)

99EndpointReference? endpoint; 126static EndpointReference? GetEndpointOrDefault(IResourceWithEndpoints resourceWithEndpoints, string endpointName) 128var reference = resourceWithEndpoints.GetEndpoint(endpointName);

ExpressionResolverTests.cs (3)

197public EndpointReference PrimaryEndpoint { get; } 214EndpointReference Endpoint1 => new(this, "endpoint1"); 215EndpointReference Endpoint2 => new(this, "endpoint2");

ProjectResourceTests.cs (2)

632var http = resource.GetEndpoint("http"); 633var https = resource.GetEndpoint("https");

WithEndpointTests.cs (3)

254var ep0 = container.GetEndpoint("ep0"); 255var ep1 = container.GetEndpoint("ep1"); 256var ep2 = container.GetEndpoint("ep2");

WithEnvironmentTests.cs (3)

233var endpoint = container.GetEndpoint("primary"); 282var endpoint = container.GetEndpoint("primary"); 308var endpoint = container.GetEndpoint("primary");

WithUrlsTests.cs (2)

330var httpEndpoint = servicea.Resource.GetEndpoint("http"); 364var httpEndpoint = servicea.Resource.GetEndpoint("http");

ValkeyResource.cs (2)

14private EndpointReference? _primaryEndpoint; 34public EndpointReference PrimaryEndpoint => _primaryEndpoint ??= new(this, PrimaryEndpointName);

YarpFunctionalTests.cs (1)

38var endpoint = yarp.Resource.GetEndpoint("http");