ServiceEndpoint

Internal\ServiceEndpointImpl.cs (1)

9internal sealed class ServiceEndpointImpl(EndPoint endPoint, IFeatureCollection? features = null) : ServiceEndpoint

Configuration\ConfigurationServiceEndpointProvider.cs (8)

107List<ServiceEndpoint> resolved = []; 134foreach (var ep in resolved) 146foreach (var ep in resolved) 158foreach (var ep in resolved) 191private void AddEndpoint(List<ServiceEndpoint> endpoints, IConfigurationSection section, string endpointName) 229private ServiceEndpoint CreateEndpoint(EndPoint endPoint) 231var serviceEndpoint = ServiceEndpoint.Create(endPoint);

Configuration\ConfigurationServiceEndpointProvider.Log.cs (1)

25internal static void ConfiguredEndpoints(ILogger logger, string serviceName, string path, IList<ServiceEndpoint> endpoints, int added)

ConfigurationServiceEndpointProviderOptions.cs (1)

21public Func<ServiceEndpoint, bool> ShouldApplyHostNameMetadata { get; set; } = _ => false;

Http\HttpServiceEndpointResolver.cs (3)

32public async ValueTask<ServiceEndpoint> GetEndpointAsync(HttpRequestMessage request, CancellationToken cancellationToken) 197public async ValueTask<(bool Valid, ServiceEndpoint? Endpoint)> TryGetEndpointAsync(object? context, CancellationToken cancellationToken) 207var result = _selector.GetEndpoint(context);

Http\ResolvingHttpClientHandler.cs (1)

25var result = await _resolver.GetEndpointAsync(request, cancellationToken).ConfigureAwait(false);

Http\ResolvingHttpDelegatingHandler.cs (2)

46var result = await _resolver.GetEndpointAsync(request, cancellationToken).ConfigureAwait(false); 61internal static Uri GetUriWithEndpoint(Uri uri, ServiceEndpoint serviceEndpoint, ServiceDiscoveryOptions options)

LoadBalancing\IServiceEndpointSelector.cs (1)

22ServiceEndpoint GetEndpoint(object? context);

LoadBalancing\RoundRobinServiceEndpointSelector.cs (2)

12private IReadOnlyList<ServiceEndpoint>? _endpoints; 21public ServiceEndpoint GetEndpoint(object? context)

PassThrough\PassThroughServiceEndpointProvider.cs (2)

19var ep = ServiceEndpoint.Create(endPoint);

ServiceEndpointBuilder.cs (2)

14private readonly List<ServiceEndpoint> _endpoints = new(); 35public IList<ServiceEndpoint> Endpoints => _endpoints;

ServiceEndpointWatcher.Log.cs (1)

28static string GetEndpointString(ServiceEndpoint ep)

IServiceEndpointBuilder.cs (1)

17IList<ServiceEndpoint> Endpoints { get; }

ServiceEndpoint.cs (3)

26/// Creates a new <see cref="ServiceEndpoint"/>. 30/// <returns>A newly initialized <see cref="ServiceEndpoint"/>.</returns> 31public static ServiceEndpoint Create(EndPoint endPoint, IFeatureCollection? features = null)

ServiceEndpointSource.cs (5)

17private readonly List<ServiceEndpoint>? _endpoints; 25public ServiceEndpointSource(List<ServiceEndpoint>? endpoints, IChangeToken changeToken, IFeatureCollection features) 38public IReadOnlyList<ServiceEndpoint> Endpoints => _endpoints ?? (IReadOnlyList<ServiceEndpoint>)[]; 68public ServiceEndpoint[] Endpoints => value.Endpoints.ToArray();

DnsServiceEndpointProvider.cs (4)

31var endpoints = new List<ServiceEndpoint>(); 57ServiceEndpoint CreateEndpoint(EndPoint endPoint) 59var serviceEndpoint = ServiceEndpoint.Create(endPoint);

DnsServiceEndpointProviderBase.cs (3)

23private List<ServiceEndpoint>? _lastEndpointCollection; 90foreach (var ep in eps) 105protected void SetResult(List<ServiceEndpoint> endpoints, TimeSpan validityPeriod)

DnsServiceEndpointProviderOptions.cs (1)

34public Func<ServiceEndpoint, bool> ShouldApplyHostNameMetadata { get; set; } = _ => false;

DnsSrvServiceEndpointProvider.cs (4)

34var endpoints = new List<ServiceEndpoint>(); 67ServiceEndpoint CreateEndpoint(EndPoint endPoint) 69var serviceEndpoint = ServiceEndpoint.Create(endPoint);

DnsSrvServiceEndpointProviderOptions.cs (1)

42public Func<ServiceEndpoint, bool> ShouldApplyHostNameMetadata { get; set; } = _ => false;

ConfigurationServiceEndpointResolverTests.cs (4)

43var ep = Assert.Single(initialResult.EndpointSource.Endpoints); 101var ep = Assert.Single(initialResult.EndpointSource.Endpoints); 116var ep = Assert.Single(initialResult.EndpointSource.Endpoints); 131var ep = Assert.Single(initialResult.EndpointSource.Endpoints);

ExtensionsServicePublicApiTests.cs (3)

169var action = () => ServiceEndpoint.Create(endPoint); 198List<ServiceEndpoint>? endpoints = null; 211List<ServiceEndpoint>? endpoints = null;

PassThroughServiceEndpointResolverTests.cs (1)

38var ep = Assert.Single(initialResult.EndpointSource.Endpoints);

ServiceEndpointResolverTests.cs (11)

91collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.1"), 8080))); 96collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.2"), 8888))); 114var sep = Assert.Single(initialResult.Endpoints); 143collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.1"), 8080))); 148collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.2"), 8888))); 163var sep = Assert.Single(initialResult.Endpoints); 179collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.1"), 8080))); 184collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.2"), 8888))); 199var endpoint = await resolver.GetEndpointAsync(httpRequest, CancellationToken.None); 231collection.Endpoints.Add(ServiceEndpoint.Create(new IPEndPoint(IPAddress.Parse("127.1.1.1"), 8080))); 284var sep = Assert.Single(result.Endpoints);

ServiceEndpointTests.cs (4)

29var serviceEndpoint = ServiceEndpoint.Create(endpoint); 38var serviceEndpoint = ServiceEndpoint.Create(endpoint);

ServiceDiscoveryDestinationResolver.cs (1)

65foreach (var endpoint in result.Endpoints)