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

96await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 104await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 119await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 128var cachedResource = Assert.Single(repositoryContext.Repository.GetResources()); 129var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 130var span = Assert.Single(Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(cachedResource.ResourceKey), cancellationToken: CancellationToken.None)).PagedResult.Items).Spans); 131var instrument = Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(cachedResource.ResourceKey)); 151await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 159await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 193reopenedContext.Repository.GetResource(new ResourceKey("backend", "TestId"))); 196var span = Assert.Single(reopenedContext.Repository.GetTrace(GetHexId("peer-trace"))!.Spans); 207await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 215await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 227using var listener = ActivityListenerHelper.Create(historicalContext.Repository.SqlActivitySource, onActivityStopped: activities.Enqueue); 229var firstResource = Assert.Single(historicalContext.Repository.GetResources()); 233var secondResource = Assert.Single(historicalContext.Repository.GetResources()); 234var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(firstResource.ResourceKey)); 260await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 278var resource = Assert.Single(reopenedContext.Repository.GetResources()); 280var instrument = Assert.Single(reopenedContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 296await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 312var log = Assert.Single((await repositoryContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 318var log = Assert.Single((await historicalContext.Repository.GetLogsAsync(CreateLogsContext(), cancellationToken: CancellationToken.None)).Items); 322Assert.Equal(logId, historicalContext.Repository.GetLog(logId)!.InternalId); 349await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 376var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 382var trace = Assert.Single((await historicalContext.Repository.GetTracesAsync(GetTracesRequest.ForResourceKey(new ResourceKey("TestService", "TestId")), cancellationToken: CancellationToken.None)).PagedResult.Items); 410await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 430var summary = Assert.Single(historicalContext.Repository.GetInstrumentSummaries(resourceKey)); 434var instrument = await historicalContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 469await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 502await reopenedContext.Repository.AddMetricsAsync(changedContext, new RepeatedField<ResourceMetrics> 513var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 542await repositoryContext.Repository.AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 579await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 594await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 609await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 674await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 708await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 754await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 791await repositoryContext.Repository.AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 818await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 826await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 841await repositoryContext.Repository.AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 857await repositoryContext.Repository.ClearStructuredLogsAsync(); 859await repositoryContext.Repository.ClearTracesAsync(); 861await repositoryContext.Repository.ClearMetricsAsync(); 872await repositoryContext.Repository.AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 880await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 896await repositoryContext.Repository.ClearStructuredLogsAsync(); 897await repositoryContext.Repository.ClearTracesAsync(); 917await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 932await repositoryContext.Repository.AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>

61var repository = context.Repository;