197 references to DefaultTimeout
Aspire.Dashboard.Tests (197)
ChannelExtensionsTests.cs (1)
185await read2Task.DefaultTimeout();
Integration\BlazorWebSocketOriginTests.cs (1)
25using var response = await client.SendAsync(request).DefaultTimeout();
Integration\DashboardClientAuthTests.cs (4)
42await using var server = await CreateResourceServiceServerAsync(loggerFactory, useHttps).DefaultTimeout(); 43await using var client = await CreateDashboardClientAsync(activitySource, loggerFactory, server.Url, authMode: ResourceClientAuthMode.Unsecured).DefaultTimeout(); 59await using var server = await CreateResourceServiceServerAsync(loggerFactory, useHttps).DefaultTimeout(); 60await using var client = await CreateDashboardClientAsync(activitySource, loggerFactory, server.Url, authMode: ResourceClientAuthMode.ApiKey, configureOptions: options => options.ResourceServiceClient.ApiKey = "TestApiKey!").DefaultTimeout();
Integration\FrontendBrowserTokenAuthTests.cs (17)
43var response = await client.GetAsync("/").DefaultTimeout(); 65var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 72var response2 = await client.GetAsync(DashboardUrls.StructuredLogsUrl()).DefaultTimeout(); 111var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 116var response2 = await client.GetAsync(new Uri(httpBaseAddress, DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 121var response3 = await client.GetAsync(new Uri(httpBaseAddress, DashboardUrls.StructuredLogsUrl())).DefaultTimeout(); 154var httpsResponse = await client.GetAsync(new Uri(new Uri(httpsEndpoint.GetResolvedAddress()), DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 155var httpResponse = await client.GetAsync(new Uri(new Uri(httpEndpoint.GetResolvedAddress()), DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 197await client.GetAsync(new Uri(httpsBaseAddress, DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 198await client.GetAsync(new Uri(httpBaseAddress, DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey))).DefaultTimeout(); 200var signoutResponse = await client.GetAsync(new Uri(httpsBaseAddress, "/api/signout")).DefaultTimeout(); 240var response1 = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 245var response2 = await client.GetAsync(DashboardUrls.StructuredLogsUrl()).DefaultTimeout(); 276var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 301var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: apiKey)).DefaultTimeout(); 325var response = await client.GetAsync(DashboardUrls.LoginUrl(returnUrl: DashboardUrls.TracesUrl(), token: "Wrong!")).DefaultTimeout(); 350var response = await client.PostAsJsonAsync("/api/validatetoken", new { Token = requestToken }).DefaultTimeout();
Integration\FrontendOpenIdConnectAuthTests.cs (4)
19await using var authority = await MockOpenIdAuthority.CreateAsync().DefaultTimeout(); 39var response = await client.GetAsync("/").DefaultTimeout(); 62await using var authority = await MockOpenIdAuthority.CreateAsync().DefaultTimeout(); 84var response = await client.GetAsync("/").DefaultTimeout();
Integration\HealthTests.cs (4)
37var response = await client.SendAsync(request).DefaultTimeout(); 54var response = await client.GetAsync($"/{DashboardUrls.HealthBasePath}").DefaultTimeout(); 57var activity = await observation.Task.DefaultTimeout(); 78var exported = await observation.Task.DefaultTimeout();
Integration\OtlpCorsHttpServiceTests.cs (5)
35var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 59var responseMessage1 = await httpClient.SendAsync(preflightRequest1).DefaultTimeout(); 73var responseMessage2 = await httpClient.SendAsync(preflightRequest2).DefaultTimeout(); 100var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout(); 128var responseMessage = await httpClient.SendAsync(preflightRequest).DefaultTimeout();
Integration\OtlpGrpcServiceTests.cs (16)
41var message = await response.ResponseAsync.DefaultTimeout(); 42var headers = await response.ResponseHeadersAsync.DefaultTimeout(); 65var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync).DefaultTimeout(); 92var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest(), metadata).ResponseAsync).DefaultTimeout(); 119var response = await client.ExportAsync(new ExportLogsServiceRequest(), metadata).ResponseAsync.DefaultTimeout(); 148var response = await client.ExportAsync(new ExportLogsServiceRequest(), metadata).ResponseAsync.DefaultTimeout(); 195var response1 = await client.ExportAsync(new ExportLogsServiceRequest(), metadata).ResponseAsync.DefaultTimeout(); 230var options = await tcs.Task.DefaultTimeout(); 237var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest(), metadata).ResponseAsync).DefaultTimeout(); 264using var response = await httpClient.SendAsync(request).DefaultTimeout(); 268Assert.Equal(string.Empty, await response.Content.ReadAsStringAsync().DefaultTimeout()); 294var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync).DefaultTimeout(); 319var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync).DefaultTimeout(); 358var response = await client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync.DefaultTimeout(); 398var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync).DefaultTimeout(); 437var ex = await Assert.ThrowsAsync<RpcException>(() => client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync).DefaultTimeout();
Integration\OtlpHttpJsonTests.cs (14)
510var responseMessage = await httpClient.PostAsync("/v1/traces", content).DefaultTimeout(); 516var responseBody = await responseMessage.Content.ReadAsStringAsync().DefaultTimeout(); 570var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 576var responseBody = await responseMessage.Content.ReadAsStringAsync().DefaultTimeout(); 647var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 653var responseBody = await responseMessage.Content.ReadAsStringAsync().DefaultTimeout(); 697var responseMessage = await httpClient.PostAsync("/v1/metrics", content).DefaultTimeout(); 703var responseBody = await responseMessage.Content.ReadAsStringAsync().DefaultTimeout(); 749var responseMessage = await httpClient.PostAsync("/v1/metrics", content).DefaultTimeout(); 755var responseBody = await responseMessage.Content.ReadAsStringAsync().DefaultTimeout(); 843var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 867var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 885var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 903var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout();
Integration\OtlpHttpServiceTests.cs (18)
54var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(TestConstants.LongTimeoutDuration); 57var response = ExportLogsServiceResponse.Parser.ParseFrom(await responseMessage.Content.ReadAsByteArrayAsync().DefaultTimeout()); 80var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 130var responseMessage = await httpClient.PostAsync(path, content).DefaultTimeout(); 135Assert.Equal(string.Empty, await responseMessage.Content.ReadAsStringAsync().DefaultTimeout()); 204var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 232var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 260var responseMessage = await httpClient.SendAsync(requestMessage).DefaultTimeout(); 263var response = ExportLogsServiceResponse.Parser.ParseFrom(await responseMessage.Content.ReadAsByteArrayAsync().DefaultTimeout()); 294var responseMessage = await httpClient.PostAsync("/v1/logs", content).DefaultTimeout(); 324var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 355var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 401var responseMessage = await client.SendAsync(requestMessage).DefaultTimeout(); 424var responseMessage = await client.PostAsync("/v1/logs", content).DefaultTimeout(); 453var responseMessage = await client.PostAsync("/v1/traces", content).DefaultTimeout(); 457var response = ExportTraceServiceResponse.Parser.ParseFrom(await responseMessage.Content.ReadAsByteArrayAsync().DefaultTimeout()); 482var responseMessage = await client.PostAsync("/v1/metrics", content).DefaultTimeout(); 486var response = ExportMetricsServiceResponse.Parser.ParseFrom(await responseMessage.Content.ReadAsByteArrayAsync().DefaultTimeout());
Integration\ResponseCompressionTests.cs (2)
27var response = await client.SendAsync(request).DefaultTimeout(); 50var response = await client.SendAsync(request).DefaultTimeout();
Integration\StartupTests.cs (12)
190var exitCode = await runTask.DefaultTimeout(); 281}).DefaultTimeout(); 333var browserTokenConfigFile = await CreateBrowserTokenConfigFileAsync(fileConfigDirectory, initialFrontendBrowserToken).DefaultTimeout(); 386}).DefaultTimeout(); 468var response = await httpClient.SendAsync(request).DefaultTimeout(); 474var serviceResponse = await client.ExportAsync(new ExportLogsServiceRequest()).ResponseAsync.DefaultTimeout(); 569var responseMessage = await httpClient.SendAsync(request).DefaultTimeout(); 579var response = ExportLogsServiceResponse.Parser.ParseFrom(await responseMessage.Content.ReadAsByteArrayAsync().DefaultTimeout()); 849var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 996var response = await client.GetAsync("/").DefaultTimeout(); 1075var response = await client.SendAsync(request).DefaultTimeout(); 1262var exitCode = await app.RunAsync(CancellationToken.None).DefaultTimeout();
Integration\TelemetryApiTests.cs (21)
67var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 87var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 113var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 140var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 145Assert.Equal(string.Empty, await response.Content.ReadAsStringAsync().DefaultTimeout()); 161var response = await httpClient.GetAsync("/api/telemetry/logs").DefaultTimeout(); 183var response = await httpClient.GetAsync("/api/telemetry/logs?traceId=some-trace-id").DefaultTimeout(); 205var response = await httpClient.GetAsync($"/api/telemetry/spans?hasError=true&limit={int.MaxValue}").DefaultTimeout(); 226var response = await httpClient.GetAsync("/api/telemetry/spans?resource=unknown-resource").DefaultTimeout(); 245var response = await httpClient.GetAsync($"/api/telemetry/logs?severity=Error&limit={int.MaxValue}").DefaultTimeout(); 266var response = await httpClient.GetAsync("/api/telemetry/logs?resource=unknown-resource").DefaultTimeout(); 286var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 310var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 336var response = await httpClient.GetAsync("/api/telemetry/spans").DefaultTimeout(); 358using var response = await httpClient.GetAsync("/api/telemetry/spans?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 389var response = await httpClient.GetAsync("/api/telemetry/logs?follow=true", HttpCompletionOption.ResponseHeadersRead, cts.Token).DefaultTimeout(); 419var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout(); 441var response = await httpClient.GetAsync("/api/telemetry/traces?hasError=true&limit=10").DefaultTimeout(); 463var response = await httpClient.GetAsync("/api/telemetry/traces?resource=unknownresource").DefaultTimeout(); 482var response = await httpClient.GetAsync("/api/telemetry/traces/nonexistent-trace-id").DefaultTimeout(); 505var response = await httpClient.GetAsync("/api/telemetry/traces").DefaultTimeout();
Integration\TerminalWebSocketAuthenticationTests.cs (1)
23? await MockOpenIdAuthority.CreateAsync().DefaultTimeout()
LocalBrowserStorageTests.cs (8)
74var result = await localStorage.GetUnprotectedAsync<int>("MyKey").DefaultTimeout(); 100var result = await localStorage.GetUnprotectedAsync<int>("MyKey").DefaultTimeout(); 125var result = await localStorage.GetUnprotectedAsync<int>("MyKey").DefaultTimeout(); 145var result = await localStorage.GetUnprotectedAsync<int>("MyKey").DefaultTimeout(); 164var result = await storage.GetAsync<int>("MyKey").DefaultTimeout(); 180var result = await storage.GetAsync<int>("MyKey").DefaultTimeout(); 195var result = await localStorage.GetUnprotectedAsync<int>("MyKey").DefaultTimeout(); 214var result = await storage.GetAsync<int>("MyKey").DefaultTimeout();
Middleware\ValidateTokenMiddlewareTests.cs (16)
21using var host = await SetUpHostAsync(FrontendAuthMode.Unsecured, string.Empty).DefaultTimeout(); 22var response = await host.GetTestClient().GetAsync("/login?t=test").DefaultTimeout(); 29using var host = await SetUpHostAsync(FrontendAuthMode.Unsecured, string.Empty).DefaultTimeout(); 30var response = await host.GetTestClient().GetAsync("/login?t=test&returnUrl=/test").DefaultTimeout(); 37using var host = await SetUpHostAsync(FrontendAuthMode.BrowserToken, "token").DefaultTimeout(); 38var response = await host.GetTestClient().GetAsync("/login?t=wrong").DefaultTimeout(); 45using var host = await SetUpHostAsync(FrontendAuthMode.BrowserToken, "token").DefaultTimeout(); 46var response = await host.GetTestClient().GetAsync("/login?t=wrong&returnUrl=/test").DefaultTimeout(); 53using var host = await SetUpHostAsync(FrontendAuthMode.BrowserToken, "token").DefaultTimeout(); 54var response = await host.GetTestClient().GetAsync("/login?t=token").DefaultTimeout(); 61using var host = await SetUpHostAsync(FrontendAuthMode.BrowserToken, "token").DefaultTimeout(); 62var response = await host.GetTestClient().GetAsync("/login?t=token&returnUrl=/test").DefaultTimeout(); 74using var host = await SetUpHostAsync(FrontendAuthMode.Unsecured, string.Empty).DefaultTimeout(); 75var response = await host.GetTestClient().GetAsync($"/login?t=test&returnUrl={Uri.EscapeDataString(returnUrl)}").DefaultTimeout(); 87using var host = await SetUpHostAsync(FrontendAuthMode.BrowserToken, "token").DefaultTimeout(); 88var response = await host.GetTestClient().GetAsync($"/login?t=token&returnUrl={Uri.EscapeDataString(returnUrl)}").DefaultTimeout();
Model\DashboardClientTests.cs (28)
69new Uri($"wss://dashboard.example.com/api/apphost-terminal?terminalId=terminal&viewId={session.Id}"), CancellationToken.None).DefaultTimeout(); 80var message = await socket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None).DefaultTimeout(); 135Assert.Equal(0, await stream.ReadAsync(new byte[1]).AsTask().DefaultTimeout()); 191using var socket = await client.ConnectAsync(uri, CancellationToken.None).DefaultTimeout(); 192var message = await socket.ReceiveAsync(new ArraySegment<byte>(new byte[64]), CancellationToken.None).DefaultTimeout(); 203var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => client.ConnectAsync(uri, CancellationToken.None).DefaultTimeout()); 345var (_, subscription) = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 373var (_, subscription) = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 398await Assert.ThrowsAsync<ObjectDisposedException>(() => client.SubscribeResourcesAsync(CancellationToken.None)).DefaultTimeout(); 411_ = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 440var (initialData, subscription) = await subscribeTask.DefaultTimeout(); 516var (snapshot, _) = await subscription.DefaultTimeout(); 582var (snapshot, _) = await client.SubscribeResourcesAsync(CancellationToken.None).DefaultTimeout(); 628Assert.Equal(1, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 635Assert.Equal(2, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 644Assert.Equal(3, await subscriptionsStarted.Reader.ReadAsync().AsTask().DefaultTimeout()); 654var (snapshot, _) = await subscription.DefaultTimeout(); 1068CancellationToken.None).DefaultTimeout(); 1090var response = await commandTask.DefaultTimeout(); 1118Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 1130Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 1144Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 1147Assert.True(await disposed.Reader.ReadAsync().AsTask().DefaultTimeout()); 1149Assert.True(await disposed.Reader.ReadAsync().AsTask().DefaultTimeout()); 1172Assert.True(await updates.MoveNextAsync().AsTask().DefaultTimeout()); 1190await Assert.ThrowsAnyAsync<OperationCanceledException>(() => next).DefaultTimeout(); 1204await Assert.ThrowsAnyAsync<OperationCanceledException>(() => next).DefaultTimeout(); 1225Assert.False(await updates.MoveNextAsync().AsTask().DefaultTimeout());
Model\SqliteResourceRepositoryTests.cs (3)
53Assert.True(await enumerator.MoveNextAsync().AsTask().DefaultTimeout()); 57Assert.True(await enumerator.MoveNextAsync().AsTask().DefaultTimeout()); 77Assert.True(await enumerator.MoveNextAsync().AsTask().DefaultTimeout());
Model\TelemetryExportServiceTests.cs (6)
776using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 824using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 875using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 935using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 989using var zipStream = await service.ExportSelectedAsync(selectedResources, CancellationToken.None).DefaultTimeout(); 998var jsonContent = await reader.ReadToEndAsync().DefaultTimeout();
OtlpApiKeyAuthenticationHandlerTests.cs (10)
22var handler = await CreateAuthHandlerAsync(primaryApiKey: "abc", secondaryApiKey: null, otlpApiKeyHeader: null).DefaultTimeout(); 25var result = await handler.AuthenticateAsync().DefaultTimeout(); 36var handler = await CreateAuthHandlerAsync(primaryApiKey: new string('!', 1000), secondaryApiKey: null, otlpApiKeyHeader: new string('!', 999)).DefaultTimeout(); 39var result = await handler.AuthenticateAsync().DefaultTimeout(); 50var handler = await CreateAuthHandlerAsync(primaryApiKey: new string('!', 1000), secondaryApiKey: null, otlpApiKeyHeader: new string('!', 1000)).DefaultTimeout(); 53var result = await handler.AuthenticateAsync().DefaultTimeout(); 67var handler = await CreateAuthHandlerAsync(primaryApiKey, secondaryApiKey, otlpApiKeyHeader).DefaultTimeout(); 70var result = await handler.AuthenticateAsync().DefaultTimeout(); 80var handler = await CreateAuthHandlerAsync(primaryApiKey: "abc", secondaryApiKey: "", otlpApiKeyHeader: "").DefaultTimeout(); 83var result = await handler.AuthenticateAsync().DefaultTimeout();
ResourceOutgoingPeerResolverTests.cs (2)
362Assert.Null(await dashboardClient.ActivityOnSubscribe.Task.DefaultTimeout()); 388Assert.Null(await callbackValue.Task.DefaultTimeout());
TelemetryRepositoryTests\LogTests.cs (1)
864var callbackValue = await tcs.Task.DefaultTimeout();
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (2)
62await Assert.ThrowsAnyAsync<OperationCanceledException>(() => queryTask).DefaultTimeout(); 81await Assert.ThrowsAnyAsync<OperationCanceledException>(() => queryTask).DefaultTimeout();
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (1)
200await tcs.Task.DefaultTimeout();