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

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 1683var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1719var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 1750await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1772var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1773var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1800await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1822var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1823var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1877await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1901var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1902var initialInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1913await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1937var refreshedInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1967await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 1992var resource = Assert.Single(repositoryContext.Repository.GetResources()); 1993var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2021var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2040await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2059return (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2097await repositoryContext.Repository.AsWriter().AddMetricsAsync(addContext, new RepeatedField<ResourceMetrics> 2113var resource = Assert.Single(repositoryContext.Repository.GetResources()); 2114var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2136var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2179var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2261var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2317var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 2379await repositoryContext.Repository.AsWriter().AddMetricsAsync(new AddContext(), new RepeatedField<ResourceMetrics> 2384await repositoryContext.Repository.AsWriter().ClearMetricsAsync(); 2387await repositoryContext.Repository.AsWriter().AddMetricsAsync(context, new RepeatedField<ResourceMetrics> 2394Assert.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()); 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 3185await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3207var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3225await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3245var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3263await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3284var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3304await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3325var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3346await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3368var result = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 3398await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3432var resources = repositoryContext.Repository.GetResources(); 3436var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3461await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3486var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3512await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3535var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3562await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3583var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3602await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3672var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3692await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 3725var fieldResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3740var textResult = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3761await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3783var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3803await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3825var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3847var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3866await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3886var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3911await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans>() 3932var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 3950await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 3971var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4008await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4034var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4060await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4084var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4111await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4135var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4162await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4221var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4248await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4276var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4303await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4329var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4355await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4384var result = await repositoryContext.Repository.GetSpansAsync(new GetSpansRequest 4413await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), new RepeatedField<ResourceSpans> 4458var traces = await repositoryContext.Repository.GetTracesAsync(new GetTracesRequest 4486await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4492var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4510await repositoryContext.Repository.AsWriter().AddTracesAsync( 4513await repositoryContext.Repository.AsWriter().AddTracesAsync( 4517var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4538var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository); 4569await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4575await repositoryContext.Repository.AsWriter().AddTracesAsync( 4579var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4602await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4608await repositoryContext.Repository.AsWriter().AddTracesAsync( 4611await repositoryContext.Repository.AsWriter().AddTracesAsync( 4614await repositoryContext.Repository.AsWriter().AddTracesAsync( 4618var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4669await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4694await repositoryContext.Repository.AsWriter().AddTracesAsync(context, 4726var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4737await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4755await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4774var trace = Assert.IsType<OtlpTrace>(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4775var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4793await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4833await repositoryContext.Repository.AsWriter().AddTracesAsync(context, [resourceSpans]); 4837var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4852await repositoryContext.Repository.AsWriter().AddTracesAsync(new AddContext(), 4902await repositoryContext.Repository.AsWriter().ClearSelectedSignalsAsync(new Dictionary<string, HashSet<AspireDataType>> 4907Assert.Null(repositoryContext.Repository.GetTrace(GetHexId("1"))); 4908Assert.NotNull(repositoryContext.Repository.GetTrace(GetHexId("2"))); 4910var summary = Assert.Single((await repositoryContext.Repository.GetTraceSummariesAsync(new GetTracesRequest 4936var repository = Assert.IsType<SqliteTelemetryRepository>(repositoryContext.Repository);