5 instantiations of SqliteTelemetryRepository
Aspire.Dashboard (1)
ServiceClient\RepositoryFactory.cs (1)
19new SqliteTelemetryRepository(
Aspire.Dashboard.Components.Tests (2)
Shared\FluentUISetupHelpers.cs (2)
181using var writer = new SqliteTelemetryRepository( 230return new SqliteTelemetryRepository(
Aspire.Dashboard.Tests (2)
Model\DashboardSqliteDatabaseTests.cs (1)
79using var telemetryRepository = new SqliteTelemetryRepository(
Shared\SqliteRepositoryTestHelpers.cs (1)
141var repository = new SqliteTelemetryRepository(
306 references to SqliteTelemetryRepository
Aspire.Dashboard (2)
Otlp\Storage\SqliteTelemetryRepository.cs (2)
74/// Initializes a new instance of the <see cref="SqliteTelemetryRepository"/> class. 96Logger = loggerFactory.CreateLogger<SqliteTelemetryRepository>(),
Aspire.Dashboard.Components.Tests (153)
Controls\ApplicationSummaryTests.cs (4)
159await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 432var inner = provider.GetRequiredService<SqliteTelemetryRepository>(); 445await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>
Controls\GenAIVisualizerDialogTests.cs (8)
49telemetryRepository: Services.GetRequiredService<SqliteTelemetryRepository>(), 129telemetryRepository: Services.GetRequiredService<SqliteTelemetryRepository>(), 153var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 210var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 295var repository = Services.GetRequiredService<SqliteTelemetryRepository>();
Dialogs\ManageDataDialogTests.cs (2)
214var repository = Services.GetRequiredService<SqliteTelemetryRepository>();
Layout\NavigationAvailabilityProviderTests.cs (1)
82return Services.GetRequiredService<SqliteTelemetryRepository>().AddLogsAsync(new AddContext(),
Layout\ResourceRowAvailabilityTests.cs (11)
167var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 201var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 259var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 354var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 395var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 428await TelemetryHelpSetupHelpers.AddSignalAsync(Services.GetRequiredService<SqliteTelemetryRepository>(), AspireDataType.StructuredLogs);
Layout\ResourcesLayoutActivityTests.cs (17)
45services.AddSingleton<ITelemetryRepository>(provider => new TestTelemetryRepository(provider.GetRequiredService<SqliteTelemetryRepository>()) 57await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 94new TestTelemetryRepository(provider.GetRequiredService<SqliteTelemetryRepository>()) 100var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 158var inner = provider.GetRequiredService<SqliteTelemetryRepository>(); 189await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), 318var inner = services.GetRequiredService<SqliteTelemetryRepository>(); 333await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 417var inner = provider.GetRequiredService<SqliteTelemetryRepository>(); 432await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 484var inner = provider.GetRequiredService<SqliteTelemetryRepository>(); 502await Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>
Layout\ResourcesLayoutTests.cs (2)
2827await Services.GetRequiredService<SqliteTelemetryRepository>().ClearSelectedSignalsAsync(new() { ["worker"] = [AspireDataType.Resource] }); 3001return Services.GetRequiredService<SqliteTelemetryRepository>().AddLogsAsync(new AddContext(),
Pages\MetricsTests.cs (53)
55var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 73await Services.GetRequiredService<SqliteTelemetryRepository>().AddMetricsAsync(new(), 95var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 234var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 385var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 445var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 516var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 665var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 716var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 759var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 869var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 942var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1009var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1051var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1117var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1191var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1412var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1474var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1544var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1693var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1754var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1810var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1898var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1944var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 2014var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 2048var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 2095var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>();
Pages\ResourceOverviewConsoleTests.cs (1)
175Services.GetRequiredService<SqliteTelemetryRepository>().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>
Pages\ResourceOverviewEmptyPanelsTests.cs (4)
358var inner = provider.GetRequiredService<SqliteTelemetryRepository>(); 370var repository = Services.GetRequiredService<SqliteTelemetryRepository>();
Pages\ResourcesTests.cs (3)
995var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1047private static async Task AddErrorLog(SqliteTelemetryRepository repository, string resourceName)
Pages\StructuredLogsTests.cs (6)
48var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 68var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 277var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>();
Pages\TraceDetailsTests.cs (31)
50var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 120var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 168var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 245var inner = services.GetRequiredService<SqliteTelemetryRepository>(); 260var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 304var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 371var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 439var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 521var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 598var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 691var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 821var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 907var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1007var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1082var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 1152SqliteTelemetryRepository repository,
Pages\TracesTests.cs (6)
75var repository = Services.GetRequiredService<SqliteTelemetryRepository>(); 132var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>(); 226var telemetryRepository = Services.GetRequiredService<SqliteTelemetryRepository>();
Shared\FluentUISetupHelpers.cs (4)
181using var writer = new SqliteTelemetryRepository( 223context.Services.AddSingleton<SqliteTelemetryRepository>(services => 238context.Services.AddSingleton<ITelemetryRepository>(services => services.GetRequiredService<SqliteTelemetryRepository>()); 239context.Services.AddSingleton<ITelemetryRepositoryWriter>(services => services.GetRequiredService<SqliteTelemetryRepository>());
Aspire.Dashboard.Tests (151)
Integration\StartupTests.cs (2)
116var telemetryRepository = Assert.IsType<SqliteTelemetryRepository>(app.Services.GetRequiredService<ITelemetryRepository>());
Model\DashboardDataSourceTests.cs (1)
1667private static async Task<SqliteRepositoryTestContext<SqliteTelemetryRepository>> CreateTelemetryRepositoryAsync(
Model\DashboardSqliteDatabaseTests.cs (1)
79using var telemetryRepository = new SqliteTelemetryRepository(
Model\GenAIVisualizerDialogViewModelTests.cs (31)
28var repository = repositoryContext.Repository; 69var repository = repositoryContext.Repository; 128var repository = repositoryContext.Repository; 226var repository = repositoryContext.Repository; 295var repository = repositoryContext.Repository; 388var repository = repositoryContext.Repository; 444var repository = repositoryContext.Repository; 494var repository = repositoryContext.Repository; 618var repository = repositoryContext.Repository; 692var repository = repositoryContext.Repository; 813var repository = repositoryContext.Repository; 858var repository = repositoryContext.Repository; 935var repository = repositoryContext.Repository; 1012var repository = repositoryContext.Repository; 1111var repository = repositoryContext.Repository; 1209var repository = repositoryContext.Repository; 1253var repository = repositoryContext.Repository; 1296var repository = repositoryContext.Repository; 1403var repository = repositoryContext.Repository; 1476var repository = repositoryContext.Repository; 1578var repository = repositoryContext.Repository; 1682SqliteTelemetryRepository repository, 1699var repository = repositoryContext.Repository; 1737var repository = repositoryContext.Repository; 1836var repository = repositoryContext.Repository; 1920var repository = repositoryContext.Repository; 1991var repository = repositoryContext.Repository; 2076var repository = repositoryContext.Repository; 2167var repository = repositoryContext.Repository; 2253var repository = repositoryContext.Repository; 2315var repository = repositoryContext.Repository;
Model\ResourceMenuBuilderTests.cs (10)
43SqliteTelemetryRepository repository, 90var repository = repositoryContext.Repository; 121var repository = repositoryContext.Repository; 210var repository = repositoryContext.Repository; 268var repository = repositoryContext.Repository; 303var repository = repositoryContext.Repository; 352var repository = repositoryContext.Repository; 390var repository = repositoryContext.Repository; 435var repository = repositoryContext.Repository; 478var repository = repositoryContext.Repository;
Model\StructuredLogsPageViewModelTests.cs (1)
223private static async Task<StructureLogsDetailsViewModel> CreateLogDetailsViewModelAsync(SqliteTelemetryRepository repository, LogLevel severity, string message)
Model\TelemetryExportServiceTests.cs (2)
1286private static async Task AddTestData(SqliteTelemetryRepository repository, string resourceName, string instanceId) 1345private static async Task<SqliteRepositoryTestContext<SqliteTelemetryRepository>> CreateRepositoryAsync(
Model\TelemetryImportServiceTests.cs (18)
29private static TelemetryImportService CreateImportService(SqliteTelemetryRepository repository, bool disableImport = false, DashboardActivitySource? activitySource = null) 40var repository = repositoryContext.Repository; 60var repository = repositoryContext.Repository; 76var repository = repositoryContext.Repository; 102var repository = repositoryContext.Repository; 126var repository = repositoryContext.Repository; 150var repository = repositoryContext.Repository; 193var repository = repositoryContext.Repository; 230var repository = repositoryContext.Repository; 248var repository = repositoryContext.Repository; 266var repository = repositoryContext.Repository; 284var repository = repositoryContext.Repository; 302var sourceRepository = sourceRepositoryContext.Repository; 330var targetRepository = targetRepositoryContext.Repository; 355var sourceRepository = sourceRepositoryContext.Repository; 389var targetRepository = targetRepositoryContext.Repository; 434var sourceRepository = sourceRepositoryContext.Repository; 462var targetRepository = targetRepositoryContext.Repository;
Shared\SqliteRepositoryTestHelpers.cs (6)
15public static SqliteRepositoryTestContext<SqliteTelemetryRepository> CreateTemporaryTelemetryRepository( 65public static SqliteRepositoryTestContext<SqliteTelemetryRepository> CreateTelemetryRepository( 99public static async Task<SqliteRepositoryTestContext<SqliteTelemetryRepository>> CreateTelemetryRepositoryAsync( 133private static SqliteRepositoryTestContext<SqliteTelemetryRepository> CreateTelemetryRepository( 141var repository = new SqliteTelemetryRepository( 148return new SqliteRepositoryTestContext<SqliteTelemetryRepository>(database, repository);
TelemetryApiServiceTests.cs (47)
27var repository = repositoryContext.Repository; 49var repository = repositoryContext.Repository; 75var repository = repositoryContext.Repository; 90var repository = repositoryContext.Repository; 114var repository = repositoryContext.Repository; 142var repository = repositoryContext.Repository; 168var repository = repositoryContext.Repository; 194var repository = repositoryContext.Repository; 215var repository = repositoryContext.Repository; 236var repository = repositoryContext.Repository; 258var repository = repositoryContext.Repository; 287var repository = repositoryContext.Repository; 324var repository = repositoryContext.Repository; 346var repository = repositoryContext.Repository; 371var repository = repositoryContext.Repository; 386var repository = repositoryContext.Repository; 402var repository = repositoryContext.Repository; 424var repository = repositoryContext.Repository; 453var repository = repositoryContext.Repository; 477var repository = repositoryContext.Repository; 503var repository = repositoryContext.Repository; 523var repository = repositoryContext.Repository; 547var repository = repositoryContext.Repository; 567var repository = repositoryContext.Repository; 585var repository = repositoryContext.Repository; 603var repository = repositoryContext.Repository; 621var repository = repositoryContext.Repository; 639var repository = repositoryContext.Repository; 655var repository = repositoryContext.Repository; 673var repository = repositoryContext.Repository; 695var repository = repositoryContext.Repository; 713var repository = repositoryContext.Repository; 736private static async Task AddSpans(SqliteTelemetryRepository repository, int count, int startMinuteSpacing = 1) 749private static async Task AddSpansToRepository(SqliteTelemetryRepository repository, IEnumerable<Span> spans) 771private static async Task AddTracesWithStatus(SqliteTelemetryRepository repository) 784private static async Task AddLogs(SqliteTelemetryRepository repository, string[] messages, SeverityNumber severity = SeverityNumber.Info) 798private static async Task AddLogsToRepository(SqliteTelemetryRepository repository, RepeatedField<LogRecord> logRecords) 817private static TelemetryApiService CreateService(SqliteTelemetryRepository repository) 837var repository = repositoryContext.Repository; 860var repository = repositoryContext.Repository; 897var repository = repositoryContext.Repository; 930var repository = repositoryContext.Repository; 965var repository = repositoryContext.Repository; 992var repository = repositoryContext.Repository; 1019var repository = repositoryContext.Repository; 1047var repository = repositoryContext.Repository; 1071var repository = repositoryContext.Repository;
TelemetryRepositoryTests\HistogramTests.cs (1)
85Assert.Equal(endTimeUnixNano / SqliteTelemetryRepository.MetricTimeBucketWidthUnixNano, reader.GetInt64(1));
TelemetryRepositoryTests\LogTests.cs (4)
1833var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1897var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);
TelemetryRepositoryTests\MetricsTests.cs (14)
2129Assert.Equal(secondEnd / SqliteTelemetryRepository.MetricTimeBucketWidthUnixNano, reader.GetInt64(1)); 2193Assert.Equal(finalEnd / SqliteTelemetryRepository.MetricTimeBucketWidthUnixNano, reader.GetInt64(1)); 2524var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2551var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2960var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3042var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3086var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3129var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (4)
33command.CommandText = "EXPLAIN QUERY PLAN " + SqliteTelemetryRepository.ResourceSignalAvailabilitySql; 63var queryTask = SqliteTelemetryRepository.RunReadAsync(token => 99var queryTask = SqliteTelemetryRepository.RunReadAsync<object?>(_ => 1070private static async Task<SqliteRepositoryTestContext<SqliteTelemetryRepository>> CreateRepositoryAsync(
TelemetryRepositoryTests\TelemetryReceiptTests.cs (3)
30var repository = context.Repository; 59var repository = context.Repository; 139private static Task AddSignalAsync(SqliteTelemetryRepository repository, AspireDataType signal) => signal switch
TelemetryRepositoryTests\TelemetryRepositoryTestBase.cs (2)
43SqliteRepositoryTestContext<SqliteTelemetryRepository> context; 61var repository = context.Repository;
TelemetryRepositoryTests\TraceTests.cs (4)
4626var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 5024var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);