170await destination.Repository.AsWriter().AddMetricsAsync(new AddContext(), request.ResourceMetrics); 171var imported = await GetInstrumentAsync(destination.Repository, rollup); 305await context.Repository.AsWriter().AddMetricsAsync(addContext, 311var instrument = await GetInstrumentAsync(context.Repository, rollup: false); 323var rolledUp = await GetInstrumentAsync(context.Repository, rollup: true); 370await context.Repository.AsWriter().AddMetricsAsync(addContext, 378var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 402await context.Repository.AsWriter().AddMetricsAsync(addContext, 407var instrument = await GetInstrumentAsync(context.Repository, rollup: false); 859await source.Repository.AsWriter().AddMetricsAsync(addContext, 864var instrument = await GetInstrumentAsync(source.Repository, rollup); 878await destination.Repository.AsWriter().AddMetricsAsync(importContext, request.ResourceMetrics); 882var imported = await GetInstrumentAsync(destination.Repository, rollup); 934await context.Repository.AsWriter().AddMetricsAsync(addContext, 940await context.Repository.AsWriter().AddMetricsAsync(addContext, 944var instrument = await GetInstrumentAsync(context.Repository, rollup); 969await context.Repository.AsWriter().AddMetricsAsync(addContext, 975var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 988await context.Repository.AsWriter().AddMetricsAsync(addContext, 994var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 1181await context.Repository.AsWriter().AddMetricsAsync(addContext, 1187var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 1203await context.Repository.AsWriter().AddMetricsAsync(addContext, 1208var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 1353await source.Repository.AsWriter().AddMetricsAsync(addContext, [CreateMetrics(temporality, first, second)]); 1357var instrument = await GetInstrumentAsync(source.Repository, rollup); 1374await destination.Repository.AsWriter().AddMetricsAsync(importContext, request.ResourceMetrics); 1377var imported = await GetInstrumentAsync(destination.Repository, rollup); 1439await context.Repository.AsWriter().AddMetricsAsync(addContext, 1444Assert.Empty((await GetInstrumentAsync(context.Repository, rollup: false)).Dimensions); 1475await context.Repository.AsWriter().AddMetricsAsync(addContext, 1480var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 1492await context.Repository.AsWriter().AddMetricsAsync(addContext, 1501var instrument = await GetInstrumentAsync(context.Repository, rollup: false); 1510await context.Repository.AsWriter().AddMetricsAsync(addContext, 1516AssertPercentiles(await GetInstrumentAsync(context.Repository, rollup: true), [100, 100, 100]); 1548await context.Repository.AsWriter().AddMetricsAsync(addContext, 1550await context.Repository.AsWriter().AddMetricsAsync(addContext, 1564await context.Repository.AsWriter().AddMetricsAsync(new AddContext(), 1567var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 1583await context.Repository.AsWriter().AddMetricsAsync(new AddContext(), 1586var instrument = await GetInstrumentAsync(context.Repository, rollup: true); 1596await context.Repository.AsWriter().AddMetricsAsync(new AddContext(), 1600var instrument = await GetInstrumentAsync(context.Repository, rollup: false);

40await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 59var resources = repositoryContext.Repository.GetResources(); 67var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 90var propertyKeys = await repositoryContext.Repository.GetLogPropertyKeysAsync(resources[0].ResourceKey, TestContext.Current.CancellationToken); 100await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 123await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 185var summaries = await repositoryContext.Repository.GetLogSummariesAsync(context, cancellationToken: CancellationToken.None); 186var logs = await repositoryContext.Repository.GetLogsAsync(context, cancellationToken: CancellationToken.None); 225var latestSummaries = await repositoryContext.Repository.GetLogSummariesAsync(latestContext, cancellationToken: CancellationToken.None); 226var latestLogs = await repositoryContext.Repository.GetLogsAsync(latestContext, cancellationToken: CancellationToken.None); 252var filtered = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 270var emptyPage = await repositoryContext.Repository.GetLogSummariesAsync(new GetLogsContext 280var emptyLogsPage = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 296await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs> 317var logs = (await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 335var actual = await repositoryContext.Repository.GetLogsFieldValuesAsync(field, TestContext.Current.CancellationToken); 344Assert.Empty(await repositoryContext.Repository.GetLogsFieldValuesAsync(KnownStructuredLogFields.TimestampField, TestContext.Current.CancellationToken)); 355await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 374var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 396await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 426var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 458await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 500var unviewedCounts1 = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 508repositoryContext.Repository.MarkViewedErrorLogs(new ResourceKey("TestService", "1")); 510var unviewedCounts2 = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 517repositoryContext.Repository.MarkViewedErrorLogs(null); 519var unviewedCounts3 = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 530using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, () => Task.CompletedTask); 534await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 571var unviewedCounts = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 582using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: new ResourceKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 586await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 623var unviewedCounts = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 635using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 639await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 661var unviewedCounts = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 674var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 693var propertyKeys = await repositoryContext.Repository.GetLogPropertyKeysAsync(new ResourceKey("TestService", "UnknownResource"), TestContext.Current.CancellationToken); 706repositoryContext.Repository.OnNewResources(() => 714await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext1, new RepeatedField<ResourceLogs>() 734var resources = repositoryContext.Repository.GetResources(); 744repositoryContext.Repository.OnNewLogs(resources[0].ResourceKey, SubscriptionType.Read, () => 751await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext2, new RepeatedField<ResourceLogs>() 772var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 790var subscription = repositoryContext.Repository.OnNewResources(() => 799await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 830var subscription = repositoryContext.Repository.OnNewResources(() => 843await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 887await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 906var resources = repositoryContext.Repository.GetResources(); 914var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 967var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Read, async () => 985await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1007await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1040await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1059var resourceKey = repositoryContext.Repository.GetResources().First().ResourceKey; 1062Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1070Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1087await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1107var result = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1109ResourceKeys = [repositoryContext.Repository.GetResources().Single().ResourceKey], 1127await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1146var resourceKey = repositoryContext.Repository.GetResources().First().ResourceKey; 1149Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1157Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1174await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1205var resources = repositoryContext.Repository.GetResources(); 1218var logs1 = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1241var logs2 = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1273await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1317var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1348var propertyKeys = await repositoryContext.Repository.GetLogPropertyKeysAsync(resourceKey, TestContext.Current.CancellationToken); 1361await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1402await repositoryContext.Repository.AsWriter().ClearStructuredLogsAsync(); 1407var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1426await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1467await repositoryContext.Repository.AsWriter().ClearStructuredLogsAsync(new ResourceKey("resource1", "123")); 1472var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1500await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1541await repositoryContext.Repository.AsWriter().ClearStructuredLogsAsync(new ResourceKey("resource1", null)); 1546var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1567await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1586var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1608await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1627var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1649await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1668var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1692await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1711var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1734await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 1753var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1772await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1811var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext 1833var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1897var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);

42await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 59var resource = Assert.Single(repositoryContext.Repository.GetResources()); 61var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 146await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 163var resource = Assert.Single(repositoryContext.Repository.GetResources()); 164var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 328await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 345var resource = Assert.Single(repositoryContext.Repository.GetResources()); 347var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 382await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 399var resource = Assert.Single(repositoryContext.Repository.GetResources()); 400var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 424await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 457var resources = repositoryContext.Repository.GetResources(); 467var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 498var instrumentSummary = repositoryContext.Repository.GetInstrumentSummary(resources[0].ResourceKey, "test-meter2", "test2"); 501Assert.Null(repositoryContext.Repository.GetInstrumentSummary(resources[0].ResourceKey, "test-meter2", "missing")); 522await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 544var resources = repositoryContext.Repository.GetResources(); 552var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 623await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 645var resources = repositoryContext.Repository.GetResources(); 653var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 684await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 703var resource = Assert.Single(repositoryContext.Repository.GetResources()); 704var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 736await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 763var resources = repositoryContext.Repository.GetResources(); 771var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 806var filteredInstrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 835await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 872var resource = Assert.Single(repositoryContext.Repository.GetResources()); 873var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 892await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 911var resourceKey = Assert.Single(repositoryContext.Repository.GetResources()).ResourceKey; 913Assert.Equal(s_testTime.AddMinutes(2), repositoryContext.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "test")); 914Assert.Null(repositoryContext.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "missing")); 925await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 951var resources = repositoryContext.Repository.GetResources(); 959var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1004await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1060var instruments = repositoryContext.Repository.GetInstrumentSummaries(resourceKey); 1077var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1111await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1164await repositoryContext.Repository.AsWriter().ClearMetricsAsync(); 1170var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1174var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 1186await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1239await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", "456")); 1245var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1253var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1268var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1280var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 1298var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1313var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1336await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1389await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", null)); 1395var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1398var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1409var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1421var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 1438var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1453var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1478await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1502var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1523await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1546var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1557repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("TestService", "TestId")), 1584await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1602var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1648await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1666var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1683await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1713var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1772await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1791var resources = Assert.Single(repositoryContext.Repository.GetResources()); 1793var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1843await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1862var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1887await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1925var instrument1 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1942var instrument2 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1963await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1985var resources = repositoryContext.Repository.GetResources(); 1993var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 2018await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2036var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2076await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> { resourceMetrics }); 2080var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2419await context.Repository.AsWriter().AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2422var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 2443await context.Repository.AsWriter().AddMetricsAsync(addContext, [CreateResourceMetrics(first), CreateResourceMetrics(second)]); 2446var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 2475await context.Repository.AsWriter().AddMetricsAsync(addContext, [CreateResourceMetrics(metric)]); 2479var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 2485EndTime = context.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "test"), 2504await context.Repository.AsWriter().AddMetricsAsync(addContext, 2508var instrument = await context.Repository.GetInstrumentAsync(new GetInstrumentRequest 2524var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2551var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2574await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2596var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2597var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2624await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2646var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2647var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2701await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2725var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2726var initialInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2737await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2761var refreshedInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2791await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2816var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2817var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2845var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2864await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2883return (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2921await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2937var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2938var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2960var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3042var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3086var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3129var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 3208await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 3213await repositoryContext.Repository.AsWriter().ClearMetricsAsync(); 3216await repositoryContext.Repository.AsWriter().AddMetricsAsync(context, new RepeatedField<ResourceMetrics> 3223Assert.Single(repositoryContext.Repository.GetInstrumentSummaries(CreateResource().GetResourceKey()));

21await AddResource(repositoryContext.Repository, "app2"); 22await AddResource(repositoryContext.Repository, "app1"); 25var resources = repositoryContext.Repository.GetResources(); 41var app1 = repositoryContext.Repository.GetResourceByCompositeName("app1-TestId"); 42var app2 = repositoryContext.Repository.GetResourceByCompositeName("APP2-TESTID"); 43var notFound = repositoryContext.Repository.GetResourceByCompositeName("APP2_TESTID"); 63await AddResource(repositoryContext.Repository, "app2"); 64await AddResource(repositoryContext.Repository, "app1", instanceId: "123"); 65await AddResource(repositoryContext.Repository, "app1", instanceId: "456"); 68var resources1 = repositoryContext.Repository.GetResources(new ResourceKey("app1", InstanceId: null)); 84var resources2 = repositoryContext.Repository.GetResources(new ResourceKey("app2", InstanceId: null)); 101await AddResource(repositoryContext.Repository, "app2"); 102await AddResource(repositoryContext.Repository, "app1", instanceId: "def"); 103await AddResource(repositoryContext.Repository, "app1", instanceId: "abc"); 106var resources = repositoryContext.Repository.GetResources(); 135await AddResource(repositoryContext.Repository, "app1", guid1); 136await AddResource(repositoryContext.Repository, "app1", guid2); 139var resources = repositoryContext.Repository.GetResources(); 159await AddResource(repositoryContext.Repository, "app1", guid1); 160await AddResource(repositoryContext.Repository, "app1", guid2); 163var resources = repositoryContext.Repository.GetResources();

29await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 47Assert.Equal(3, repositoryContext.Repository.GetResources().Count); 51await repositoryContext.Repository.AsWriter().AddTracesAsync(failContext, new RepeatedField<ResourceSpans> 69Assert.Equal(3, repositoryContext.Repository.GetResources().Count); 81await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 101await repositoryContext.Repository.AsWriter().AddTracesAsync(successContext, new RepeatedField<ResourceSpans> 138await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 156var resources = repositoryContext.Repository.GetResources(); 157var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 162await repositoryContext.Repository.AsWriter().AddMetricsAsync(failContext, new RepeatedField<ResourceMetrics> 181instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 195await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 228await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 259await repositoryContext.Repository.AsWriter().AddLogsAsync(setupContext, new RepeatedField<ResourceLogs> 279await repositoryContext.Repository.AsWriter().AddLogsAsync(failContext, new RepeatedField<ResourceLogs> 320await repositoryContext.Repository.AsWriter().AddMetricsAsync(setupContext, new RepeatedField<ResourceMetrics> 340await repositoryContext.Repository.AsWriter().AddMetricsAsync(failContext, new RepeatedField<ResourceMetrics> 382await repositoryContext.Repository.AsWriter().AddTracesAsync(setupContext, new RepeatedField<ResourceSpans> 402await repositoryContext.Repository.AsWriter().AddTracesAsync(failContext, new RepeatedField<ResourceSpans> 452await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, scopeLogs); 457await repositoryContext.Repository.AsWriter().AddLogsAsync(failContext, new RepeatedField<ResourceLogs> 498await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> { rs }); 503await repositoryContext.Repository.AsWriter().AddTracesAsync(failContext, new RepeatedField<ResourceSpans> 543await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> { rm }); 548await repositoryContext.Repository.AsWriter().AddMetricsAsync(failContext, new RepeatedField<ResourceMetrics>

33using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 44Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 45Assert.Null(repositoryContext.Repository.GetResource(resourceKey)); 46Assert.Empty((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 55Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 56var resource = repositoryContext.Repository.GetResource(resourceKey); 58Assert.NotEmpty(repositoryContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 59Assert.Single((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 64await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 87await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 121await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 211await AddTestData(repositoryContext.Repository, "resource1", "123"); 212await AddTestData(repositoryContext.Repository, "resource2", "456"); 215var unviewedBefore = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 226await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 229var unviewedAfter = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 235var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 239var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 242var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 247var resource2Logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 251var resource2Traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 254var resource2Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource2", "456")); 264await AddTestData(repositoryContext.Repository, "resource1", "111"); 265await AddTestData(repositoryContext.Repository, "resource2", "222"); 266await AddTestData(repositoryContext.Repository, "resource3", "333"); 273await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 276var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 282var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 285var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "111")); 288var resource3Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource3", "333")); 292var resource2 = repositoryContext.Repository.GetResource(new ResourceKey("resource2", "222")); 302await AddTestData(repositoryContext.Repository, "resource1", "123"); 305var resourceBefore = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 313await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 316var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 320var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 323var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 327var resources = repositoryContext.Repository.GetResources(); 337await AddTestData(repositoryContext.Repository, "resource1", "123"); 344await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 347var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 351var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 354var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 357var metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 370await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 396await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 415await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 459await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 489await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 515await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 534await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 577await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 607await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 669await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 701await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 747await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 776await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 816await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1")], Filters = [] }, cts.Token)) 836await AddTestData(repositoryContext.Repository, "resource1", "inst1"); 837await AddTestData(repositoryContext.Repository, "resource2", "inst2"); 838await AddTestData(repositoryContext.Repository, "resource3", "inst3"); 844var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [key1, key2], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 857await AddTestData(repositoryContext.Repository, "service1", "inst1"); 858await AddTestData(repositoryContext.Repository, "service2", "inst2"); 859await AddTestData(repositoryContext.Repository, "service3", "inst3"); 862var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 881await AddTestData(repositoryContext.Repository, "service1", "inst1"); 882await AddTestData(repositoryContext.Repository, "service2", "inst2"); 883await AddTestData(repositoryContext.Repository, "service3", "inst3"); 891await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 912await AddTestData(repositoryContext.Repository, "service1", "inst1"); 913await AddTestData(repositoryContext.Repository, "service2", "inst2"); 914await AddTestData(repositoryContext.Repository, "service3", "inst3"); 922await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 956await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 982await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1002await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1048await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1074await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1094await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1131await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1158await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest 1182await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1235await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1261await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1279await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1333await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 1359await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1377await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 1493await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token))

48await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 71var resources = repositoryContext.Repository.GetResources(); 80var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 102await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 175var summaries = await repositoryContext.Repository.GetTraceSummariesAsync(request, cancellationToken: CancellationToken.None); 176var traces = await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None); 210var latestSummaries = await repositoryContext.Repository.GetTraceSummariesAsync(latestRequest, cancellationToken: CancellationToken.None); 211var latestTraces = await repositoryContext.Repository.GetTracesAsync(latestRequest, cancellationToken: CancellationToken.None); 221var emptyPage = await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 239await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 306var traces = (await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items; 307var summaries = (await repositoryContext.Repository.GetTraceSummariesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items; 318await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 341await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 364var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 371var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(summary.TraceId)); 387await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 412var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 437await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 459await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 485var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 521await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 543var resources = repositoryContext.Repository.GetResources(); 551var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 573await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 597var resources = repositoryContext.Repository.GetResources(); 605var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 623await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 644await repositoryContext.Repository.AsWriter().AddTracesAsync(context, new RepeatedField<ResourceSpans> 664var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 684await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 708var resources = repositoryContext.Repository.GetResources(); 716var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 738await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 756await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 778var resources = repositoryContext.Repository.GetResources(); 786var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 815await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext1, new RepeatedField<ResourceSpans>() 835await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext2, new RepeatedField<ResourceSpans>() 854var resources = repositoryContext.Repository.GetResources(); 862var traces1 = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 884await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext3, new RepeatedField<ResourceSpans>() 903var traces2 = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 934await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 957var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 986await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 1025var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1062await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 1101var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1148await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext1, new RepeatedField<ResourceSpans>() 1167var traces1 = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1182var traces2 = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1192var trace1 = repositoryContext.Repository.GetTrace(GetHexId("1"))!; 1193var trace2 = repositoryContext.Repository.GetTrace(GetHexId("1"))!; 1219await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1241var resources = repositoryContext.Repository.GetResources(); 1249var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1299await AddTrace(repositoryContext.Repository, "1", s_testTime); 1300var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1356await AddTrace(repositoryContext.Repository, traceId, startTime); 1365var resources = repositoryContext.Repository.GetResources(); 1373var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1453await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1477var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1502await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1546var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1563var propertyKeys = await repositoryContext.Repository.GetTracePropertyKeysAsync(resourceKey, TestContext.Current.CancellationToken); 1577await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 1606var resources = repositoryContext.Repository.GetResources(); 1617await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 1638var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1639var traces = (await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1650var actual = await repositoryContext.Repository.GetTraceFieldValuesAsync(field, TestContext.Current.CancellationToken); 1658Assert.Empty(await repositoryContext.Repository.GetTraceFieldValuesAsync(KnownTraceFields.DurationField, TestContext.Current.CancellationToken)); 1659Assert.Empty(await repositoryContext.Repository.GetTraceFieldValuesAsync(KnownTraceFields.TimestampField, TestContext.Current.CancellationToken)); 1669await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1702var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1720traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1738traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1770await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1791var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1806traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1831await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1860var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1892await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1919var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1931traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 1949await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 1968var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2001await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2022var trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2026await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2047trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2051await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2072trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2076await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2097trace = Assert.Single((await repositoryContext.Repository.GetTracesAsync(request, cancellationToken: CancellationToken.None)).PagedResult.Items); 2109await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2162var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2195var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2254await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2307await repositoryContext.Repository.AsWriter().ClearTracesAsync(); 2312var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2332await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2385await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", "123")); 2390var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2437await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2490await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 2495var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2525await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2581await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 2586var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2619await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2642var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2659var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2681var serviceNames = await repositoryContext.Repository.GetTraceFieldValuesAsync(KnownResourceFields.ServiceNameField, TestContext.Current.CancellationToken); 2691var writer = repositoryContext.Repository.AsWriter(); 2719var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 2748trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 2754var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 2785await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2805Assert.Contains(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2807await repositoryContext.Repository.AsWriter().ClearTracesAsync(); 2811Assert.DoesNotContain(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2821await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 2847repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), 2850await repositoryContext.Repository.AsWriter().ClearTracesAsync(peerResource.ResourceKey); 2852var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2861Assert.DoesNotContain(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2888await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2911var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2920var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2944resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2961traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2992await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 3018var peerResource = Assert.Single(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 3022var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 3036await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 3062Assert.Null(Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans).UninstrumentedPeer); 3067var peerResource = Assert.Single(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 3069var span = Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans); 3075Assert.Null(Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans).UninstrumentedPeer); 3076var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 3084Assert.Empty((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 3102await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 3122var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 3144await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3166var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3184await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3217var result = await repositoryContext.Repository.GetRequestSpansAsync(request, CancellationToken.None); 3246var capped = await repositoryContext.Repository.GetRequestSpansAsync(new GetRequestSpansRequest 3256var other = await repositoryContext.Repository.GetRequestSpansAsync(new GetRequestSpansRequest 3273await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3295var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3313await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3333var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3351await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3372var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3392await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3413var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3434await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3456var result = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3486await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3520var resources = repositoryContext.Repository.GetResources(); 3524var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3549await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3574var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3600await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3623var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3650await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3671var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3690await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3760var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3780await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3813var fieldResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3828var textResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3849await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3871var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3891await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3913var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3935var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3954await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3974var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3999await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 4020var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4038await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4059var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4096await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4122var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4148await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4172var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4199await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4223var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4250await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4309var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4336await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4364var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4391await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4417var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4443await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4472var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4501await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4546var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4574await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4580var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4598await repositoryContext.Repository.AsWriter().AddTracesAsync( 4601await repositoryContext.Repository.AsWriter().AddTracesAsync( 4605var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4626var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 4657await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4663await repositoryContext.Repository.AsWriter().AddTracesAsync( 4667var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4690await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4696await repositoryContext.Repository.AsWriter().AddTracesAsync( 4699await repositoryContext.Repository.AsWriter().AddTracesAsync( 4702await repositoryContext.Repository.AsWriter().AddTracesAsync( 4706var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4757await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4782await repositoryContext.Repository.AsWriter().AddTracesAsync(context, 4814var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4825await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4843await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4862var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4863var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4881await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4921await repositoryContext.Repository.AsWriter().AddTracesAsync(context, [resourceSpans]); 4925var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4940await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4990await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(new Dictionary<string, HashSet<AspireDataType>> 4995Assert.Null(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4996Assert.NotNull(repositoryContext.Repository.GetTrace(GetHexId("2"))); 4998var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 5024var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);