1065await telemetryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1081await ((IResourceRepositoryWriter)resourceContext.Repository).ReplaceResourcesAsync([new 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)) 253await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 260var actual = historicalContext.Repository.GetResources() 272var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 274Assert.False(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 280Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 284Assert.False(repositoryContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 287Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 290Assert.True(repositoryContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 294Assert.True(historicalContext.Repository.GetResource("api")!.ConsoleLogsLoaded); 295Assert.False(historicalContext.Repository.GetResource("worker")!.ConsoleLogsLoaded); 408await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 424var actual = Assert.Single(historicalContext.Repository.GetResources()); 482await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]); 486var actual = Assert.Single(historicalContext.Repository.GetResources()); 515await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync(resources); 519var actualResources = historicalContext.Repository.GetResources().OrderBy(resource => resource.Name).ToList(); 530var writer = (IResourceRepositoryWriter)repositoryContext.Repository; 544var resources = repositoryContext.Repository.GetResources().OrderBy(resource => resource.Name).ToArray(); 612await ((IResourceRepositoryWriter)repositoryContext.Repository).ReplaceResourcesAsync([resource]);

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

93Repository.Dispose();

77await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 85await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 100await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 109var cachedResource = Assert.Single(repositoryContext.Repository.GetResources()); 110var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 111var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 112var instrument = Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(cachedResource.ResourceKey)); 132await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 140await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 174reopenedContext.Repository.GetResource(new ResourceKey("backend", "TestId"))); 177var span = Assert.Single(reopenedContext.Repository.GetTrace(GetHexId("peer-trace"))!.Spans); 188await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 196await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 208using var listener = ActivityListenerHelper.Create(historicalContext.Repository.SqlActivitySource, onActivityStopped: activities.Enqueue); 210var firstResource = Assert.Single(historicalContext.Repository.GetResources()); 214var secondResource = Assert.Single(historicalContext.Repository.GetResources()); 215var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(firstResource.ResourceKey)); 241await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 259var resource = Assert.Single(reopenedContext.Repository.GetResources()); 261var instrument = Assert.Single(reopenedContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 277await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 293var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 299var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 303Assert.Equal(logId, historicalContext.Repository.GetLog(logId)!.InternalId); 330await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 357var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 363var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 391await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 411var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(resourceKey)); 415var instrument = await historicalContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 450await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 483await reopenedContext.Repository.AddMetricsAsync(changedContext, new RepeatedField<ResourceMetrics> 494var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 523await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 560await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 575await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 590await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 655await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 689await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 735await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 772await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 799await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 807await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 822await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 838await repositoryContext.Repository.ClearStructuredLogsAsync(); 840await repositoryContext.Repository.ClearTracesAsync(); 842await repositoryContext.Repository.ClearMetricsAsync(); 853await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 861await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 877await repositoryContext.Repository.ClearStructuredLogsAsync(); 878await repositoryContext.Repository.ClearTracesAsync(); 898await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 913await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>

65var sqliteRepository = context.Repository;