16 instantiations of AddressResult
Microsoft.Extensions.ServiceDiscovery.Dns (7)
FallbackDnsResolver.cs (2)
35
results[i] = new
AddressResult
63
addresses.Add(new
AddressResult
Resolver\DnsResolver.cs (5)
104
addresses.Add(new
AddressResult
(response.CreatedAt.AddSeconds(additional.Ttl), new IPAddress(additional.Data.Span)));
200
results.Add(new
AddressResult
(response.CreatedAt.AddSeconds(answer.Ttl), address));
252
addressList.Add(new
AddressResult
(response.CreatedAt.AddSeconds(answer.Ttl), address));
339
res[count] = new
AddressResult
(DateTime.MaxValue, IPAddress.IPv6Loopback);
344
res[count] = new
AddressResult
(DateTime.MaxValue, IPAddress.Loopback);
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (6)
DnsSrvServiceEndpointResolverTests.cs (6)
52
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))])
87
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))])
124
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))]),
125
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 62, 9999, "srv-b", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.IPv6Loopback)]),
175
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))]),
176
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 62, 9999, "srv-b", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.IPv6Loopback)]),
Microsoft.Extensions.ServiceDiscovery.Yarp.Tests (3)
YarpServiceDiscoveryTests.cs (3)
277
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))]),
278
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 62, 9999, "srv-b", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.IPv6Loopback)]),
279
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 62, 7777, "srv-c", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Loopback)])
76 references to AddressResult
Microsoft.Extensions.ServiceDiscovery.Dns (28)
DnsServiceEndpointProvider.cs (1)
38
foreach (
var
address in addresses)
DnsSrvServiceEndpointProvider.cs (1)
47
foreach (
var
address in record.Addresses)
FallbackDnsResolver.cs (5)
26
public async ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default)
31
var results = new
AddressResult
[addresses.Length];
54
var lookupMapping = new Dictionary<string, List<
AddressResult
>>();
59
addresses = new List<
AddressResult
>();
86
: Array.Empty<
AddressResult
>()
Resolver\DnsResolver.cs (18)
87
List<
AddressResult
> addresses = new List<
AddressResult
>();
116
public async ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default)
126
AddressResult
[] ipv4Addresses = await ipv4AddressesTask.ConfigureAwait(false);
127
AddressResult
[] ipv6Addresses = await ipv6AddressesTask.ConfigureAwait(false);
129
AddressResult
[] results = new
AddressResult
[ipv4Addresses.Length + ipv6Addresses.Length];
135
internal ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, AddressFamily addressFamily, CancellationToken cancellationToken = default)
155
static (SendQueryError error,
AddressResult
[] result) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response)
157
List<
AddressResult
> results = new List<
AddressResult
>(response.Answers.Count);
221
Dictionary<EncodedDomainName, List<
AddressResult
>> aRecordMap = new();
246
if (!aRecordMap.TryGetValue(answer.Name, out List<
AddressResult
>? addressList))
248
addressList = new List<
AddressResult
>();
279
aRecordMap.TryGetValue(currentAlias, out List<
AddressResult
>? finalAddressList);
324
private static
AddressResult
[] ResolveDnsReservedNameAddress(ReservedNameType type, AddressFamily? addressFamily)
334
AddressResult
[] res = new
AddressResult
[len];
Resolver\DnsResolver.Telemetry.cs (1)
94
AddressResult
[] addressResults => ToStringHelper(addressResults),
Resolver\IDnsResolver.cs (1)
8
ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default);
Resolver\ResultTypes.cs (1)
10
internal record struct ServiceResult(DateTime ExpiresAt, int Priority, int Weight, int Port, string Target,
AddressResult
[] Addresses);
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (43)
DnsSrvServiceEndpointResolverTests.cs (4)
24
public Func<string, AddressFamily, CancellationToken, ValueTask<
AddressResult
[]>>? ResolveIPAddressesAsyncFunc { get; set; }
25
public ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, AddressFamily addressFamily, CancellationToken cancellationToken = default) => ResolveIPAddressesAsyncFunc!.Invoke(name, addressFamily, cancellationToken);
27
public Func<string, CancellationToken, ValueTask<
AddressResult
[]>>? ResolveIPAddressesAsyncFunc2 { get; set; }
29
public ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default) => ResolveIPAddressesAsyncFunc2!.Invoke(name, cancellationToken);
Resolver\ResolveAddressesTests.cs (20)
32
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
53
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
73
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(name, AddressFamily.InterNetwork);
75
AddressResult
res = Assert.Single(results);
94
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
96
AddressResult
res = Assert.Single(results);
115
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
117
AddressResult
res = Assert.Single(results);
135
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
153
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
172
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
193
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
214
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
247
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(localhost, family);
256
AddressResult
result = Assert.Single(results);
265
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync("timeout-empty.test", AddressFamily.InterNetwork);
285
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync("example.com", AddressFamily.InterNetwork);
312
ValueTask<
AddressResult
[]> task = Resolver.ResolveIPAddressesAsync(name, AddressFamily.InterNetwork);
329
AddressResult
[] results = await task;
330
AddressResult
result = Assert.Single(results);
Resolver\ResolveServiceTests.cs (1)
34
AddressResult
addressResult = Assert.Single(result.Addresses);
Resolver\RetryTests.cs (12)
63
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
65
AddressResult
res = Assert.Single(results);
89
AddressResult
[] results = await RunWithFallbackServerHelper(hostName,
119
AddressResult
res = Assert.Single(results);
145
AddressResult
[] results = await RunWithFallbackServerHelper(hostName,
184
AddressResult
res = Assert.Single(results);
203
AddressResult
[] results = await RunWithFallbackServerHelper(hostName,
220
AddressResult
res = Assert.Single(results);
243
AddressResult
[] results = await RunWithFallbackServerHelper(hostName,
276
AddressResult
res = Assert.Single(results);
281
private async Task<
AddressResult
[]> RunWithFallbackServerHelper(string name, Func<LoopbackDnsResponseBuilder, Task> primaryHandler, Func<LoopbackDnsResponseBuilder, Task> fallbackHandler)
304
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync("nameerror-noretry", AddressFamily.InterNetwork);
Resolver\TcpFailoverTests.cs (6)
34
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
36
AddressResult
res = Assert.Single(results);
59
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork).AsTask().WaitAsync(TimeSpan.FromSeconds(10));
78
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
102
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
129
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
Microsoft.Extensions.ServiceDiscovery.Dns.Tests.Fuzzing (1)
Fuzzers\DnsResponseFuzzer.cs (1)
41
ValueTask<
AddressResult
[]> task = _resolver!.ResolveIPAddressesAsync("www.example.com", AddressFamily.InterNetwork, CancellationToken.None);
Microsoft.Extensions.ServiceDiscovery.Yarp.Tests (4)
YarpServiceDiscoveryTests.cs (4)
312
public Func<string, AddressFamily, CancellationToken, ValueTask<
AddressResult
[]>>? ResolveIPAddressesAsyncFunc { get; set; }
313
public ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, AddressFamily addressFamily, CancellationToken cancellationToken = default) => ResolveIPAddressesAsyncFunc!.Invoke(name, addressFamily, cancellationToken);
315
public Func<string, CancellationToken, ValueTask<
AddressResult
[]>>? ResolveIPAddressesAsyncFunc2 { get; set; }
317
public ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default) => ResolveIPAddressesAsyncFunc2!.Invoke(name, cancellationToken);