1414await telemetryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1430await ((IResourceRepositoryWriter)resourceContext.Repository).ReplaceResourcesAsync([new Resource

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; 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;

90var repository = repositoryContext.Repository; 121var repository = repositoryContext.Repository; 180var menuBuilder = CreateResourceMenuBuilder(repositoryContext.Repository, new TestDashboardClient(isEnabled: true)); 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;

33var vm = SpanDetailsViewModel.Create(span, repositoryContext.Repository, [resource]);

24var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 27AssertResource(Assert.Single(repositoryContext.Repository.GetResources()), resource, replicaIndex: 1); 32Assert.Equal("Running", repositoryContext.Repository.GetResource(resource.Name)!.State); 36AssertResource(Assert.Single(historicalContext.Repository.GetResources()), resource, replicaIndex: 1, state: "Running"); 44var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 45var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 59Assert.Empty(repositoryContext.Repository.GetResources()); 67var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 70var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 99var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 113await ((IResourceRepositoryWriter)restartedRepositoryContext.Repository).AddConsoleLogsAsync( 120await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 138var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 159await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 168await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None)) 184var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 194var writer = (IResourceRepositoryWriter)restartedRepositoryContext.Repository; 205await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 229await ((IResourceRepositoryWriter)repositoryContext.Repository).AddConsoleLogsAsync("api", logLines); 234await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 249var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 264await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 273await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None)) 293await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 300var actual = historicalContext.Repository.GetResources() 312var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 314Assert.False(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 320Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 324Assert.False(repositoryContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 327Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 330Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 334Assert.True(historicalContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 335Assert.False(historicalContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 448await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 464var actual = Assert.Single(historicalContext.Repository.GetResources()); 522await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 526var actual = Assert.Single(historicalContext.Repository.GetResources()); 555await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 559var actualResources = historicalContext.Repository.GetResources().OrderBy(resource => resource.Name).ToList(); 570var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 584var resources = repositoryContext.Repository.GetResources().OrderBy(resource => resource.Name).ToArray(); 652await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]);

27var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 37vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Warning, "Hello world"); 39var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Hello", [], CancellationToken.None); 49vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello world"); 51var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 61vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Warning, "Hello world"); 63var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 74vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Trace, "any message"); 76var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [], CancellationToken.None); 86vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello world"); 88var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "xyz-not-present", [], CancellationToken.None); 98vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello World"); 100var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "hello", [], CancellationToken.None); 110vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "some message"); 114var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "app1", [], CancellationToken.None); 124vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "some message"); 128var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Information", [], CancellationToken.None); 138vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello world"); 148var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 158vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello world"); 168var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 178vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Information, "Hello world"); 188var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "", [fieldFilter], CancellationToken.None); 198vm.SelectedLogEntry = await CreateLogDetailsViewModelAsync(repositoryContext.Repository, LogLevel.Warning, "Hello world"); 209var result = await vm.IsSelectedLogEntryExcludedByFiltersAsync(repositoryContext.Repository, "Hello", [fieldFilter], CancellationToken.None);

42await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 58var resources = repositoryContext.Repository.GetResources(); 60var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 110await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 126var resources = repositoryContext.Repository.GetResources(); 128var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 149await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 174var resources = repositoryContext.Repository.GetResources(); 176var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 231await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 247var resources = repositoryContext.Repository.GetResources(); 249var logs = await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 269await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 295var resources = repositoryContext.Repository.GetResources(); 297var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 348await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 368var resources = repositoryContext.Repository.GetResources(); 370var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 392await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 416var resources = repositoryContext.Repository.GetResources(); 418var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 442await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 466var resources = repositoryContext.Repository.GetResources(); 468var traces = await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(resource.ResourceKey), cancellationToken: CancellationToken.None); 525await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<OpenTelemetry.Proto.Metrics.V1.ResourceMetrics>() 544var resources = repositoryContext.Repository.GetResources(); 546var instrumentSummaries = repositoryContext.Repository.GetInstrumentSummaries(resource.ResourceKey); 552var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 607await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<OpenTelemetry.Proto.Metrics.V1.ResourceMetrics>() 632var resources = repositoryContext.Repository.GetResources(); 634var instrumentSummaries = repositoryContext.Repository.GetInstrumentSummaries(resource.ResourceKey); 640var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 688var exportService = await CreateExportServiceAsync(repositoryContext.Repository); 691await AddTestData(repositoryContext.Repository, "resource1", "111"); 692await AddTestData(repositoryContext.Repository, "resource2", "222"); 693await AddTestData(repositoryContext.Repository, "resource3", "333"); 694await AddTestData(repositoryContext.Repository, "resource4", "444"); 753await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 770var service = await CreateExportServiceAsync(repositoryContext.Repository, isDashboardClientEnabled: false); 773var selectedResources = BuildAllResourcesSelection(repositoryContext.Repository); 802await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 818var service = await CreateExportServiceAsync(repositoryContext.Repository, isDashboardClientEnabled: false); 853await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 869var service = await CreateExportServiceAsync(repositoryContext.Repository, isDashboardClientEnabled: false); 896await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 913await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 929var service = await CreateExportServiceAsync(repositoryContext.Repository, isDashboardClientEnabled: false); 932var selectedResources = BuildAllResourcesSelection(repositoryContext.Repository); 959await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 983var service = await CreateExportServiceAsync(repositoryContext.Repository, isDashboardClientEnabled: false); 986var selectedResources = BuildAllResourcesSelection(repositoryContext.Repository); 1038await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1054var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1076await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1091await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1107var span = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0].Spans[0]; 1108var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1129await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1148await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1168var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0]; 1169var logs = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items; 1190await repositoryContext.Repository.AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1210var trace = (await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items[0]; 1231await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1247var logEntry = (await repositoryContext.Repository.GetLogsAsync(GetLogsContext.ForResourceKey(repositoryContext.Repository.GetResources()[0].ResourceKey), cancellationToken: CancellationToken.None)).Items[0];

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;

53context.Repository.SubscriptionMinExecuteInterval = subscriptionMinExecuteInterval.Value; 200Repository.Dispose();

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; 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;

39await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, first)]); 50await writer.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, second, last)]); 54await writer.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, second)]); 55await writer.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, last)]); 62var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 76Assert.Equal(value.End, readOnly.Repository.GetInstrumentLatestEndTime(new ResourceKey("TestService", "TestId"), "test-meter", "histogram")); 109await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(temporality, point, point.Clone())]); 115await reopened.Repository.AddMetricsAsync(new AddContext(), [CreateMetrics(temporality, point)]); 119var instrument = await GetInstrumentAsync(readOnly.Repository, rollup); 136var filtered = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 147var afterSamples = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 191await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, point)]); 194var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 226await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, batch)]); 231var instrument = await GetInstrumentAsync(context.Repository, rollup: false); 257await context.Repository.AddMetricsAsync(new AddContext(), [CreateMetrics(AggregationTemporality.Cumulative, first)]); 268await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, stale, continued)]); 274var instrument = await GetInstrumentAsync(readOnly.Repository, rollup: true); 342await context.Repository.AddMetricsAsync(new AddContext(), 350await reopened.Repository.AddMetricsAsync(addContext, 357var instrument = await GetInstrumentAsync(reopened.Repository, rollup: false); 362AssertPercentiles(await GetInstrumentAsync(reopened.Repository, rollup: true), [100, 100, 100]); 422await context.Repository.AddMetricsAsync(addContext, 429await AssertInstrumentAsync(context.Repository); 433await AssertInstrumentAsync(reopened.Repository); 495await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, points)]); 501await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, point)]); 507var histogram = await GetInstrumentAsync(context.Repository, rollup: false); 536await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, points[..3])]); 563await context.Repository.AddMetricsAsync(addContext, [metrics]); 567var histogram = await GetInstrumentAsync(context.Repository, rollup); 574var gauge = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 605await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, first, updated, updated)]); 609await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, first)]); 610await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, updated)]); 611await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, updated)]); 616var instrument = await GetInstrumentAsync(context.Repository, rollup); 659await context.Repository.AddMetricsAsync(addContext, 667await reopened.Repository.AddMetricsAsync(retryContext, 671var instrument = await GetInstrumentAsync(reopened.Repository, rollup); 713await context.Repository.AddMetricsAsync(addContext, 719await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, retry)]); 720await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, retry)]); 724await AssertIntervalsAsync(context.Repository, points); 730await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, retry, retry)]); 733await AssertIntervalsAsync(reopened.Repository, points); 735await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, next)]); 738await AssertIntervalsAsync(reopened.Repository, [points[1], points[2], next]); 742await AssertIntervalsAsync(readOnly.Repository, [points[1], points[2], next]); 787await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, point)]); 791await AssertInstrumentAsync(context.Repository); 794await context.Repository.AddMetricsAsync(duplicateContext, [CreateMetrics(AggregationTemporality.Delta, points)]); 797await AssertInstrumentAsync(context.Repository); 802await AssertInstrumentAsync(reopened.Repository); 806await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Delta, point)]); 810await AssertInstrumentAsync(reopened.Repository); 814await AssertInstrumentAsync(readOnly.Repository); 1040await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, first, reset)]); 1047await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, continuation)]); 1050await AssertInstrumentAsync(reopened.Repository); 1053await AssertInstrumentAsync(readOnly.Repository); 1139await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, 1146var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 1240await context.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, first)]); 1243var instrument = await GetInstrumentAsync(context.Repository, rollup: false); 1251await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, reset)]); 1254var instrument = await GetInstrumentAsync(reopened.Repository, rollup); 1283await reopened.Repository.AddMetricsAsync(addContext, [CreateMetrics(AggregationTemporality.Cumulative, continued)]); 1289var finalInstrument = await GetInstrumentAsync(readOnly.Repository, rollup); 1399await context.Repository.AddMetricsAsync(addContext, 1406var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 1412EndTime = readOnly.Repository.GetInstrumentLatestEndTime(new ResourceKey("TestService", "TestId"), "test-meter", "histogram") 1526await context.Repository.AddMetricsAsync(new AddContext(), 1534await reopened.Repository.AddMetricsAsync(addContext, 1540AssertPercentiles(await GetInstrumentAsync(reopened.Repository, rollup: true), [10, 100, 100]);

1719await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1723await writer.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1750var instrument = await readOnly.Repository.GetInstrumentAsync(request, CancellationToken.None); 1757Assert.Equal(value.End, readOnly.Repository.GetInstrumentLatestEndTime(request.ResourceKey, request.MeterName, request.InstrumentName)); 1760var after = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 1784await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1789await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1814await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1817await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1824readOnly.Repository.GetInstrumentLatestEndTime(CreateResource().GetResourceKey(), "test-meter", "test")); 1843await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1860await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 1900await context.Repository.AddMetricsAsync(new AddContext(), [CreateResourceMetrics(metric)]); 1903await reopened.Repository.AddMetricsAsync(new AddContext(), [CreateResourceMetrics(metric)]); 1906var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 1945await context.Repository.AddMetricsAsync(addContext, [.. batch.Select(CreateResourceMetrics)]); 1960await reopened.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(changed)]); 1980var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 1986EndTime = readOnly.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "test")

93await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 101await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 116await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 125var cachedResource = Assert.Single(repositoryContext.Repository.GetResources()); 126var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 127var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 128var instrument = Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(cachedResource.ResourceKey)); 148await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 156await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 190reopenedContext.Repository.GetResource(new ResourceKey("backend", "TestId"))); 193var span = Assert.Single(reopenedContext.Repository.GetTrace(GetHexId("peer-trace"))!.Spans); 204await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 212await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 223var firstResource = Assert.Single(historicalContext.Repository.GetResources()); 225var secondResource = Assert.Single(historicalContext.Repository.GetResources()); 226var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(firstResource.ResourceKey)); 251await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 269var resource = Assert.Single(reopenedContext.Repository.GetResources()); 271var instrument = Assert.Single(reopenedContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 287await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 303var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 309var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 313Assert.Equal(logId, historicalContext.Repository.GetLog(logId)!.InternalId); 340await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 367var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 373var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 401await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 421var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(resourceKey)); 425var instrument = await historicalContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 483await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 502await Assert.ThrowsAsync<SqliteException>(() => reopenedContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 512await reopenedContext.Repository.AddMetricsAsync(context, new RepeatedField<ResourceMetrics> 519var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 542await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 575await reopenedContext.Repository.AddMetricsAsync(changedContext, new RepeatedField<ResourceMetrics> 586var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 615await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 652await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 667await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 682await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 747await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 781await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 827await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 864await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 891await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 899await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 914await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 930await repositoryContext.Repository.ClearStructuredLogsAsync(); 932await repositoryContext.Repository.ClearTracesAsync(); 934await repositoryContext.Repository.ClearMetricsAsync(); 945await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 953await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 969await repositoryContext.Repository.ClearStructuredLogsAsync(); 970await repositoryContext.Repository.ClearTracesAsync(); 990await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 1005await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>

30var repository = context.Repository; 38Assert.True(resumed.Repository.HasReceivedTelemetry); 52Assert.False(restarted.Repository.HasReceivedTelemetry); 59var repository = context.Repository; 81await AddSignalAsync(context.Repository, signal); 83Assert.False(context.Repository.HasReceivedTelemetry); 93await context.Repository.AddMetricsAsync(addContext, 103Assert.False(context.Repository.HasReceivedTelemetry); 120await Assert.ThrowsAsync<SqliteException>(() => AddSignalAsync(context.Repository, AspireDataType.StructuredLogs)); 122Assert.False(context.Repository.HasReceivedTelemetry); 129Assert.False(context.Repository.HasReceivedTelemetry); 132AddSignalAsync(context.Repository, AspireDataType.StructuredLogs), 133AddSignalAsync(context.Repository, AspireDataType.Traces), 134AddSignalAsync(context.Repository, AspireDataType.Metrics)); 136Assert.True(context.Repository.HasReceivedTelemetry);

61var repository = context.Repository;