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 1840var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1904var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);

33await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 66var resources = repositoryContext.Repository.GetResources(); 76var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 107var instrumentSummary = repositoryContext.Repository.GetInstrumentSummary(resources[0].ResourceKey, "test-meter2", "test2"); 110Assert.Null(repositoryContext.Repository.GetInstrumentSummary(resources[0].ResourceKey, "test-meter2", "missing")); 131await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 153var resources = repositoryContext.Repository.GetResources(); 161var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 232await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 254var resources = repositoryContext.Repository.GetResources(); 262var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 293await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 312var resource = Assert.Single(repositoryContext.Repository.GetResources()); 313var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 345await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 372var resources = repositoryContext.Repository.GetResources(); 380var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 415var filteredInstrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 444await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 481var resource = Assert.Single(repositoryContext.Repository.GetResources()); 482var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 501await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 520var resourceKey = Assert.Single(repositoryContext.Repository.GetResources()).ResourceKey; 522Assert.Equal(s_testTime.AddMinutes(2), repositoryContext.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "test")); 523Assert.Null(repositoryContext.Repository.GetInstrumentLatestEndTime(resourceKey, "test-meter", "missing")); 555await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 581var resources = repositoryContext.Repository.GetResources(); 589var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 634await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 690var instruments = repositoryContext.Repository.GetInstrumentSummaries(resourceKey); 707var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 741await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 794await repositoryContext.Repository.AsWriter().ClearMetricsAsync(); 800var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 804var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 816await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 869await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", "456")); 875var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 883var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 898var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 910var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 928var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 943var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 966await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1019await repositoryContext.Repository.AsWriter().ClearMetricsAsync(new ResourceKey("resource1", null)); 1025var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1028var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1039var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1051var resource2Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource2Key); 1068var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1083var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1108await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1132var resource1Instruments = repositoryContext.Repository.GetInstrumentSummaries(resource1Key); 1166await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1184var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1230await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1248var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1264await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1294var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1353await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1372var resources = Assert.Single(repositoryContext.Repository.GetResources()); 1374var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1424await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1443var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1468await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1506var instrument1 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1523var instrument2 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1544await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 1566var resources = repositoryContext.Repository.GetResources(); 1574var instruments = repositoryContext.Repository.GetInstrumentSummaries(resources[0].ResourceKey); 1599await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1617var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1657await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> { resourceMetrics }); 1661var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1690var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1726var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1757await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1779var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1780var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1807await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1829var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1830var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1884await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1908var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1909var initialInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1920await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1944var refreshedInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1974await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1999var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2000var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2028var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2047await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2066return (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2104await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2120var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2121var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2143var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2186var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2268var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2324var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2386await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 2391await repositoryContext.Repository.AsWriter().ClearMetricsAsync(); 2394await repositoryContext.Repository.AsWriter().AddMetricsAsync(context, new RepeatedField<ResourceMetrics> 2401Assert.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>

31using var subscription = repositoryContext.Repository.OnNewLogs(resourceKey: null, SubscriptionType.Other, () => Task.CompletedTask); 42Assert.Empty((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 43Assert.Null(repositoryContext.Repository.GetResource(resourceKey)); 44Assert.Empty((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 53Assert.Single((await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).Items); 54var resource = repositoryContext.Repository.GetResource(resourceKey); 56Assert.NotEmpty(repositoryContext.Repository.GetInstrumentSummaries(resource.ResourceKey)); 57Assert.Single((await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resourceKey], Count = 100, Filters = [], StartIndex = 0 }, cancellationToken: CancellationToken.None)).PagedResult.Items); 62await repositoryContext.Repository.AsWriter().AddLogsAsync(addContext, new RepeatedField<ResourceLogs>() 85await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics>() 119await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 209await AddTestData(repositoryContext.Repository, "resource1", "123"); 210await AddTestData(repositoryContext.Repository, "resource2", "456"); 213var unviewedBefore = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 224await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 227var unviewedAfter = repositoryContext.Repository.GetResourceUnviewedErrorLogsCount(); 233var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 237var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 240var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 245var resource2Logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 249var resource2Traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [resource2Key], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 252var resource2Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource2", "456")); 262await AddTestData(repositoryContext.Repository, "resource1", "111"); 263await AddTestData(repositoryContext.Repository, "resource2", "222"); 264await AddTestData(repositoryContext.Repository, "resource3", "333"); 271await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 274var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 280var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 283var resource1Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "111")); 286var resource3Metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource3", "333")); 290var resource2 = repositoryContext.Repository.GetResource(new ResourceKey("resource2", "222")); 300await AddTestData(repositoryContext.Repository, "resource1", "123"); 303var resourceBefore = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 311await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 314var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 318var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 321var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 325var resources = repositoryContext.Repository.GetResources(); 335await AddTestData(repositoryContext.Repository, "resource1", "123"); 342await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(selectedResources); 345var resourceAfter = repositoryContext.Repository.GetResource(new ResourceKey("resource1", "123")); 349var logs = await repositoryContext.Repository.GetLogsAsync(new GetLogsContext { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 352var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 355var metrics = repositoryContext.Repository.GetInstrumentSummaries(new ResourceKey("resource1", "123")); 368await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 394await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 412await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 456await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 486await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 512await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 530await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 573await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = [] }, cts.Token)) 603await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 665await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 697await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 743await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = [] }, linkedCts.Token)) 772await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 812await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1")], Filters = [] }, cts.Token)) 832await AddTestData(repositoryContext.Repository, "resource1", "inst1"); 833await AddTestData(repositoryContext.Repository, "resource2", "inst2"); 834await AddTestData(repositoryContext.Repository, "resource3", "inst3"); 840var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest { ResourceKeys = [key1, key2], StartIndex = 0, Count = 10, Filters = [] }, cancellationToken: CancellationToken.None); 853await AddTestData(repositoryContext.Repository, "service1", "inst1"); 854await AddTestData(repositoryContext.Repository, "service2", "inst2"); 855await AddTestData(repositoryContext.Repository, "service3", "inst3"); 858var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 877await AddTestData(repositoryContext.Repository, "service1", "inst1"); 878await AddTestData(repositoryContext.Repository, "service2", "inst2"); 879await AddTestData(repositoryContext.Repository, "service3", "inst3"); 887await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 908await AddTestData(repositoryContext.Repository, "service1", "inst1"); 909await AddTestData(repositoryContext.Repository, "service2", "inst2"); 910await AddTestData(repositoryContext.Repository, "service3", "inst3"); 918await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [new ResourceKey("service1", "inst1"), new ResourceKey("service2", "inst2")], Filters = [] }, cts.Token)) 952await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 978await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 997await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1043await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1069await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1088await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1125await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1152await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest 1175await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1228await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1254await foreach (var log in repositoryContext.Repository.WatchLogsAsync(new WatchLogsRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1271await repositoryContext.Repository.AsWriter().AddLogsAsync(new AddContext(), new RepeatedField<ResourceLogs> 1325await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 1351await foreach (var span in repositoryContext.Repository.WatchSpansAsync(new WatchSpansRequest { ResourceKeys = [], Filters = filters }, cts.Token)) 1368await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>

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()); 2198var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2257await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2310await repositoryContext.Repository.AsWriter().ClearTracesAsync(); 2315var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2335await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2388await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", "123")); 2393var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2440await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2493await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 2498var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2528await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2584await repositoryContext.Repository.AsWriter().ClearTracesAsync(new ResourceKey("resource1", null)); 2589var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2622await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2645var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2662var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2684var serviceNames = await repositoryContext.Repository.GetTraceFieldValuesAsync(KnownResourceFields.ServiceNameField, TestContext.Current.CancellationToken); 2694var writer = repositoryContext.Repository.AsWriter(); 2722var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 2751trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 2757var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 2788await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2808Assert.Contains(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2810await repositoryContext.Repository.AsWriter().ClearTracesAsync(); 2814Assert.DoesNotContain(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2824await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 2850repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), 2853await repositoryContext.Repository.AsWriter().ClearTracesAsync(peerResource.ResourceKey); 2855var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2864Assert.DoesNotContain(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 2891await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 2914var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2923var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2947resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 2964traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 2995await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 3021var peerResource = Assert.Single(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 3025var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 3039await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans> 3065Assert.Null(Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans).UninstrumentedPeer); 3070var peerResource = Assert.Single(repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true), resource => resource.UninstrumentedPeer); 3072var span = Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans); 3078Assert.Null(Assert.Single(repositoryContext.Repository.GetTrace(GetHexId("1"))!.Spans).UninstrumentedPeer); 3079var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 3087Assert.Empty((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 3105await repositoryContext.Repository.AsWriter().AddTracesAsync(addContext, new RepeatedField<ResourceSpans>() 3125var resources = repositoryContext.Repository.GetResources(includeUninstrumentedPeers: true); 3147await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3169var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3188await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3210var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3230await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3251var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3271await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3292var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3313await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3335var result = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3365await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3399var resources = repositoryContext.Repository.GetResources(); 3403var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3422await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3445var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3472await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3493var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3513await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3546var fieldResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3561var textResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3582await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3604var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3624await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3646var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3668var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3687await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3707var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3732await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3753var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3771await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3792var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3829await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3855var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3881await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3905var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3932await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3956var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3983await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4042var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4069await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4097var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4124await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4150var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4176await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4205var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4234await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4279var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4314await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4320var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4338await repositoryContext.Repository.AsWriter().AddTracesAsync( 4341await repositoryContext.Repository.AsWriter().AddTracesAsync( 4345var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4366var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 4397await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4403await repositoryContext.Repository.AsWriter().AddTracesAsync( 4407var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4430await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4436await repositoryContext.Repository.AsWriter().AddTracesAsync( 4439await repositoryContext.Repository.AsWriter().AddTracesAsync( 4442await repositoryContext.Repository.AsWriter().AddTracesAsync( 4446var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4497await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4522await repositoryContext.Repository.AsWriter().AddTracesAsync(context, 4554var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4565await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4583await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4602var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4603var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4621await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4661await repositoryContext.Repository.AsWriter().AddTracesAsync(context, [resourceSpans]); 4665var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4680await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4730await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(new Dictionary<string, HashSet<AspireDataType>> 4735Assert.Null(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4736Assert.NotNull(repositoryContext.Repository.GetTrace(GetHexId("2"))); 4738var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4764var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);