3 instantiations of OtlpInstrumentData
Aspire.Dashboard (2)
Components\Controls\Chart\MetricInstrumentDataCache.cs (1)
74return new OtlpInstrumentData
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
133return new OtlpInstrumentData
Aspire.Dashboard.Tests (1)
ChartDataCalculatorTests.cs (1)
528return new OtlpInstrumentData
74 references to OtlpInstrumentData
Aspire.Dashboard (19)
Components\Controls\Chart\ChartContainer.razor.cs (8)
22private OtlpInstrumentData? _instrument; 186private async Task UpdateInstrumentDataAsync(OtlpInstrumentData instrument) 252private async Task<(long UpdateVersion, OtlpInstrumentData? Instrument)> GetInstrumentAsync(bool useIncrementalCache, CancellationToken cancellationToken) 255OtlpInstrumentData? baseInstrument; 311var refreshedInstrument = await TelemetryRepository.GetInstrumentAsync(new GetInstrumentRequest 336var instrument = baseInstrument is not null && cursors.Count > 0 342private bool TryPublishInstrument((long UpdateVersion, OtlpInstrumentData? Instrument) result) 444private bool HaveDimensionFilterValuesChanged(OtlpInstrumentData instrument)
Components\Controls\Chart\MetricInstrumentDataCache.cs (4)
12public static List<MetricDimensionCursor> CreateCursors(OtlpInstrumentData data, TimeSpan refreshLookback, TimeSpan dataPointInterval) 39public static OtlpInstrumentData Merge( 40OtlpInstrumentData cached, 41OtlpInstrumentData refreshed,
Model\TelemetryExportService.cs (4)
198var instrumentsData = new List<OtlpInstrumentData>(); 201var instrumentData = await _dataSource.TelemetryRepository.GetInstrumentAsync(new GetInstrumentRequest 468internal static OtlpTelemetryDataJson ConvertMetricsToOtlpJson(List<OtlpInstrumentData> instruments) 488private static OtlpMetricJson ConvertInstrument(OtlpInstrumentData instrumentData)
Otlp\Storage\ITelemetryRepository.cs (1)
64Task<OtlpInstrumentData?> GetInstrumentAsync(GetInstrumentRequest request, CancellationToken cancellationToken);
Otlp\Storage\SqliteTelemetryRepository.cs (1)
231public Task<OtlpInstrumentData?> GetInstrumentAsync(GetInstrumentRequest request, CancellationToken cancellationToken) =>
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
110private OtlpInstrumentData? GetInstrumentFromDatabase(GetInstrumentRequest request, CancellationToken cancellationToken)
Aspire.Dashboard.Components.Tests (1)
Shared\TestTelemetryRepository.cs (1)
52public Task<OtlpInstrumentData?> GetInstrumentAsync(GetInstrumentRequest request, CancellationToken cancellationToken) => inner.GetInstrumentAsync(request, cancellationToken);
Aspire.Dashboard.Tests (54)
ChartDataCalculatorTests.cs (7)
457var cached = CreateInstrumentData([cachedDimension]); 458var refreshed = CreateInstrumentData([refreshedDimension, newDimension]); 464var merged = MetricInstrumentDataCache.Merge(cached, refreshed, cursors, start); 488var cached = CreateInstrumentData([cachedDimension]); 489var refreshed = CreateInstrumentData([refreshedDimension]); 494var merged = MetricInstrumentDataCache.Merge(cached, refreshed, cursors, start); 524private static OtlpInstrumentData CreateInstrumentData(List<DimensionScope> dimensions)
Integration\OtlpHttpJsonTests.cs (1)
769var instrumentData = await telemetryRepository.GetInstrumentAsync(new GetInstrumentRequest
Model\TelemetryExportServiceTests.cs (4)
549var instrumentsData = new List<OtlpInstrumentData>(); 552var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 637var instrumentsData = new List<OtlpInstrumentData>(); 640var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest
TelemetryRepositoryTests\MetricsTests.cs (40)
161var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 262var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 313var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 380var instrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 415var filteredInstrumentData = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 482var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 589var instrument = (await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 707var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 883var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 898var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 928var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 943var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1028var resource1Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1039var resource1Test2Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1068var resource2Test1Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1083var resource2Test3Instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1184var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1248var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1294var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1374var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1443var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1506var instrument1 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1523var instrument2 = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1617var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1661var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1696var instrument = await repository.GetInstrumentAsync(new GetInstrumentRequest 1728var instrument = await repository.GetInstrumentAsync(new GetInstrumentRequest 1773var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1823var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1902var initialInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1937var refreshedInstrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 1993var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2022var initialInstrument = await GetInstrumentAsync([]); 2031var refreshedInstrument = await GetInstrumentAsync(cursors); 2057async Task<OtlpInstrumentData> GetInstrumentAsync(IReadOnlyList<MetricDimensionCursor> dimensionCursors) 2114var instrument = await repositoryContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 2223var histogramInstrument = await repository.GetInstrumentAsync(new GetInstrumentRequest 2235var sumInstrument = await repository.GetInstrumentAsync(new GetInstrumentRequest 2299var instrument = await repository.GetInstrumentAsync(new GetInstrumentRequest 2362var instrument = await repository.GetInstrumentAsync(new GetInstrumentRequest
TelemetryRepositoryTests\SqliteTelemetryPersistenceTests.cs (2)
415var instrument = await historicalContext.Repository.GetInstrumentAsync(new GetInstrumentRequest 494var instrument = await reopenedContext.Repository.GetInstrumentAsync(new GetInstrumentRequest