16 instantiations of AddressResult
Microsoft.Extensions.ServiceDiscovery.Dns (9)
FallbackDnsResolver.cs (2)
35
results[i] = new
AddressResult
63
addresses.Add(new
AddressResult
Resolver\DnsResolver.cs (7)
100
addresses.Add(new
AddressResult
(response.CreatedAt.AddSeconds(additional.Ttl), new IPAddress(additional.Data.Span)));
123
res[index] = new
AddressResult
(DateTime.MaxValue, IPAddress.IPv6Loopback);
128
res[index] = new
AddressResult
(DateTime.MaxValue, IPAddress.Loopback);
161
return ValueTask.FromResult<AddressResult[]>([new
AddressResult
(DateTime.MaxValue, IPAddress.Loopback)]);
165
return ValueTask.FromResult<AddressResult[]>([new
AddressResult
(DateTime.MaxValue, IPAddress.IPv6Loopback)]);
221
results.Add(new
AddressResult
(response.CreatedAt.AddSeconds(answer.Ttl), address));
273
addressList.Add(new
AddressResult
(response.CreatedAt.AddSeconds(answer.Ttl), address));
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (4)
DnsSrvServiceEndpointResolverTests.cs (4)
44
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))]),
45
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 62, 9999, "srv-b", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.IPv6Loopback)]),
95
new ServiceResult(DateTime.UtcNow.AddSeconds(60), 99, 66, 8888, "srv-a", [new
AddressResult
(DateTime.UtcNow.AddSeconds(64), IPAddress.Parse("10.10.10.10"))]),
96
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)])
78 references to AddressResult
Microsoft.Extensions.ServiceDiscovery.Dns (30)
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 (20)
83
List<
AddressResult
> addresses = new List<
AddressResult
>();
112
public async ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, CancellationToken cancellationToken = default)
118
AddressResult
[] res = new
AddressResult
[len];
137
AddressResult
[] ipv4Addresses = await ipv4AddressesTask.ConfigureAwait(false);
138
AddressResult
[] ipv6Addresses = await ipv6AddressesTask.ConfigureAwait(false);
140
AddressResult
[] results = new
AddressResult
[ipv4Addresses.Length + ipv6Addresses.Length];
146
internal ValueTask<
AddressResult
[]> ResolveIPAddressesAsync(string name, AddressFamily addressFamily, CancellationToken cancellationToken = default)
161
return ValueTask.FromResult<
AddressResult
[]>([new AddressResult(DateTime.MaxValue, IPAddress.Loopback)]);
165
return ValueTask.FromResult<
AddressResult
[]>([new AddressResult(DateTime.MaxValue, IPAddress.IPv6Loopback)]);
168
return ValueTask.FromResult<
AddressResult
[]>([]);
176
static (SendQueryError error,
AddressResult
[] result) ProcessResponse(EncodedDomainName dnsSafeName, QueryType queryType, DnsResponse response)
178
List<
AddressResult
> results = new List<
AddressResult
>(response.Answers.Count);
242
Dictionary<EncodedDomainName, List<
AddressResult
>> aRecordMap = new();
267
if (!aRecordMap.TryGetValue(answer.Name, out List<
AddressResult
>? addressList))
269
addressList = new List<
AddressResult
>();
300
aRecordMap.TryGetValue(currentAlias, out List<
AddressResult
>? finalAddressList);
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);
70
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(name, AddressFamily.InterNetwork);
72
AddressResult
res = Assert.Single(results);
91
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
93
AddressResult
res = Assert.Single(results);
112
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
114
AddressResult
res = Assert.Single(results);
132
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
150
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
169
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
190
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
211
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync(hostName, AddressFamily.InterNetwork);
228
AddressResult
[] results = await Resolver.ResolveIPAddressesAsync("localhost", family);
229
AddressResult
result = Assert.Single(results);
238
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync("timeout-empty.test", AddressFamily.InterNetwork);
258
AddressResult
[] result = await Resolver.ResolveIPAddressesAsync("example.com", AddressFamily.InterNetwork);
285
ValueTask<
AddressResult
[]> task = Resolver.ResolveIPAddressesAsync(name, AddressFamily.InterNetwork);
302
AddressResult
[] results = await task;
303
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)
40
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);