1458await telemetryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1474await ((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]);

25var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 28AssertResource(Assert.Single(repositoryContext.Repository.GetResources()), resource, replicaIndex: 1); 33Assert.Equal("Running", repositoryContext.Repository.GetResource(resource.Name)!.State); 37AssertResource(Assert.Single(historicalContext.Repository.GetResources()), resource, replicaIndex: 1, state: "Running"); 45var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 46var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 60Assert.Empty(repositoryContext.Repository.GetResources()); 68var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 71var subscription = await repositoryContext.Repository.SubscribeResourcesAsync(CancellationToken.None); 100var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 114await ((IResourceRepositoryWriter)restartedRepositoryContext.Repository).AddConsoleLogsAsync( 121await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 139var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 160await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 169await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None)) 185var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 195var writer = (IResourceRepositoryWriter)restartedRepositoryContext.Repository; 206await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 230await ((IResourceRepositoryWriter)repositoryContext.Repository).AddConsoleLogsAsync("api", logLines); 235await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 250var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 265await foreach (var batch in historicalContext.Repository.GetConsoleLogs("api", CancellationToken.None)) 274await foreach (var batch in historicalContext.Repository.GetConsoleLogs("worker", CancellationToken.None)) 294await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 301var actual = historicalContext.Repository.GetResources() 313var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 315Assert.False(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 321Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 325Assert.False(repositoryContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 328Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 331Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 335Assert.True(historicalContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 336Assert.False(historicalContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 449await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 465var actual = Assert.Single(historicalContext.Repository.GetResources()); 523await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 527var actual = Assert.Single(historicalContext.Repository.GetResources()); 556await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 560var actualResources = historicalContext.Repository.GetResources().OrderBy(resource => resource.Name).ToList(); 571var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 585var resources = repositoryContext.Repository.GetResources().OrderBy(resource => resource.Name).ToArray(); 653await ((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]);

2113await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2117await writer.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2144var instrument = await readOnly.Repository.GetInstrumentAsync(request, CancellationToken.None); 2151Assert.Equal(value.End, readOnly.Repository.GetInstrumentLatestEndTime(request.ResourceKey, request.MeterName, request.InstrumentName)); 2154var after = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 2178await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2183await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2208await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2211await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2218readOnly.Repository.GetInstrumentLatestEndTime(CreateResource().GetResourceKey(), "test-meter", "test")); 2237await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2254await context.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2294await context.Repository.AddMetricsAsync(new AddContext(), [CreateResourceMetrics(metric)]); 2297await reopened.Repository.AddMetricsAsync(new AddContext(), [CreateResourceMetrics(metric)]); 2300var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 2339await context.Repository.AddMetricsAsync(addContext, [.. batch.Select(CreateResourceMetrics)]); 2354await reopened.Repository.AddMetricsAsync(addContext, [CreateResourceMetrics(changed)]); 2374var instrument = await readOnly.Repository.GetInstrumentAsync(new GetInstrumentRequest 2380EndTime = readOnly.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "test")

122await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 130await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 145await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 154var cachedResource = Assert.Single(repositoryContext.Repository.GetResources()); 155var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 156var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 157var instrument = Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(cachedResource.ResourceKey)); 177await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 185await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 219reopenedContext.Repository.GetResource(new ResourceKey("backend", "TestId"))); 222var span = Assert.Single(reopenedContext.Repository.GetTrace(GetHexId("peer-trace"))!.Spans); 233await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 241await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 252var firstResource = Assert.Single(historicalContext.Repository.GetResources()); 254var secondResource = Assert.Single(historicalContext.Repository.GetResources()); 255var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(firstResource.ResourceKey)); 280await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 298var resource = Assert.Single(reopenedContext.Repository.GetResources()); 300var instrument = Assert.Single(reopenedContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 316await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 332var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 338var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 342Assert.Equal(logId, historicalContext.Repository.GetLog(logId)!.InternalId); 369await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 396var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 402var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 430await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 450var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(resourceKey)); 454var instrument = await historicalContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 512await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 531await Assert.ThrowsAsync<SqliteException>(() => reopenedContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 541await reopenedContext.Repository.AddMetricsAsync(context, new RepeatedField<ResourceMetrics> 548var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 571await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 604await reopenedContext.Repository.AddMetricsAsync(changedContext, new RepeatedField<ResourceMetrics> 615var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 644await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 681await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 696await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 711await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 776await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 810await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 856await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 893await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 920await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 928await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 943await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 959await repositoryContext.Repository.ClearStructuredLogsAsync(); 961await repositoryContext.Repository.ClearTracesAsync(); 963await repositoryContext.Repository.ClearMetricsAsync(); 974await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 982await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 998await repositoryContext.Repository.ClearStructuredLogsAsync(); 999await repositoryContext.Repository.ClearTracesAsync(); 1019await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 1034await 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;