3 instantiations of ServiceEndpointSource
Microsoft.Extensions.ServiceDiscovery (1)
ServiceEndpointBuilder.cs (1)
43return new ServiceEndpointSource(_endpoints, new CompositeChangeToken(_changeTokens), _features);
Microsoft.Extensions.ServiceDiscovery.Tests (2)
ExtensionsServicePublicApiTests.cs (2)
200var action = () => new ServiceEndpointSource(endpoints, changeToken, features); 213var action = () => new ServiceEndpointSource(endpoints, changeToken, features);
30 references to ServiceEndpointSource
Microsoft.Extensions.ServiceDiscovery (18)
Internal\ServiceEndpointResolverResult.cs (2)
13internal sealed class ServiceEndpointResolverResult(ServiceEndpointSource? endpointSource, Exception? exception) 29public ServiceEndpointSource? EndpointSource { get; } = endpointSource;
LoadBalancing\IServiceEndpointSelector.cs (2)
15void SetEndpoints(ServiceEndpointSource endpoints); 18/// Selects an endpoints from the collection provided by the most recent call to <see cref="SetEndpoints(ServiceEndpointSource)"/>.
LoadBalancing\RoundRobinServiceEndpointSelector.cs (1)
15public void SetEndpoints(ServiceEndpointSource endpoints)
ServiceEndpointBuilder.cs (2)
38/// Creates a <see cref="ServiceEndpointSource"/> from the provided instance. 41public ServiceEndpointSource Build()
ServiceEndpointResolver.cs (3)
42public async ValueTask<ServiceEndpointSource> GetEndpointsAsync(string serviceName, CancellationToken cancellationToken) 190public async ValueTask<(bool Valid, ServiceEndpointSource? Endpoints)> GetEndpointsAsync(CancellationToken cancellationToken) 199var endpoints = await _watcher.GetEndpointsAsync(cancellationToken).ConfigureAwait(false);
ServiceEndpointWatcher.cs (7)
32private ServiceEndpointSource? _cachedEndpoints; 61public ValueTask<ServiceEndpointSource> GetEndpointsAsync(CancellationToken cancellationToken = default) 70return new ValueTask<ServiceEndpointSource>(cached); 77async ValueTask<ServiceEndpointSource> GetEndpointsInternal(CancellationToken cancellationToken) 79ServiceEndpointSource? result; 134ServiceEndpointSource? newEndpoints = null; 153var endpoints = builder.Build();
ServiceEndpointWatcher.Log.cs (1)
21public static void ResolutionSucceeded(ILogger logger, string serviceName, ServiceEndpointSource endpointSource)
Microsoft.Extensions.ServiceDiscovery.Abstractions (4)
IServiceEndpointBuilder.cs (2)
10/// Builder to create a <see cref="ServiceEndpointSource"/> instances. 25/// Adds a change token to the resulting <see cref="ServiceEndpointSource"/>.
ServiceEndpointSource.cs (2)
20/// Initializes a new <see cref="ServiceEndpointSource"/> instance. 61private sealed class ServiceEndpointCollectionDebuggerView(ServiceEndpointSource value)
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (3)
DnsServiceEndpointResolverTests.cs (3)
23var initialResult = await resolver.GetEndpointsAsync("https://localhost", CancellationToken.None); 27var secondResult = await resolver.GetEndpointsAsync("https://localhost", CancellationToken.None); 31var thirdResult = await resolver.GetEndpointsAsync("https://localhost", CancellationToken.None);
Microsoft.Extensions.ServiceDiscovery.Tests (4)
PassThroughServiceEndpointResolverTests.cs (1)
127var result = await resolver.GetEndpointsAsync("catalog", default);
ServiceEndpointResolverTests.cs (3)
161var initialResult = await resolver.GetEndpointsAsync("http://basket", CancellationToken.None); 247var initialEndpoints = await initialEndpointsTask; 282var result = await task;
Microsoft.Extensions.ServiceDiscovery.Yarp (1)
ServiceDiscoveryDestinationResolver.cs (1)
60var result = await resolver.GetEndpointsAsync(serviceName, cancellationToken).ConfigureAwait(false);