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

89var repository = repositoryContext.Repository; 119var repository = repositoryContext.Repository; 171var repository = repositoryContext.Repository; 228var repository = repositoryContext.Repository; 262var repository = repositoryContext.Repository; 310var repository = repositoryContext.Repository; 347var repository = repositoryContext.Repository; 391var repository = repositoryContext.Repository; 433var repository = repositoryContext.Repository;

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

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; 196Repository.Dispose();

27var repository = repositoryContext.Repository; 49var repository = repositoryContext.Repository; 74var repository = repositoryContext.Repository; 89var repository = repositoryContext.Repository; 113var repository = repositoryContext.Repository; 141var repository = repositoryContext.Repository; 167var repository = repositoryContext.Repository; 193var repository = repositoryContext.Repository; 214var repository = repositoryContext.Repository; 235var repository = repositoryContext.Repository; 257var repository = repositoryContext.Repository; 286var repository = repositoryContext.Repository; 323var repository = repositoryContext.Repository; 345var repository = repositoryContext.Repository; 370var repository = repositoryContext.Repository; 385var repository = repositoryContext.Repository; 401var repository = repositoryContext.Repository; 423var repository = repositoryContext.Repository; 452var repository = repositoryContext.Repository; 476var repository = repositoryContext.Repository; 502var repository = repositoryContext.Repository; 522var repository = repositoryContext.Repository; 546var repository = repositoryContext.Repository; 566var repository = repositoryContext.Repository; 584var repository = repositoryContext.Repository; 602var repository = repositoryContext.Repository; 620var repository = repositoryContext.Repository; 638var repository = repositoryContext.Repository; 654var repository = repositoryContext.Repository; 672var repository = repositoryContext.Repository; 694var repository = repositoryContext.Repository; 712var repository = repositoryContext.Repository; 836var repository = repositoryContext.Repository; 859var repository = repositoryContext.Repository; 896var repository = repositoryContext.Repository; 929var repository = repositoryContext.Repository; 964var repository = repositoryContext.Repository; 991var repository = repositoryContext.Repository; 1018var repository = repositoryContext.Repository; 1046var repository = repositoryContext.Repository; 1070var repository = repositoryContext.Repository;

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>

61var repository = context.Repository;