121 references to OtlpAggregationTemporality
Aspire.Dashboard (48)
Components\Controls\Chart\ChartDataCalculator.cs (6)
159public List<double?> CalculateCounterIncreaseValues(List<DimensionScope> dimensions, DateTimeOffset startTime, OtlpAggregationTemporality temporality) 161if (temporality == OtlpAggregationTemporality.Delta) 267internal static List<double?> CalculateCounterIncreases(IReadOnlyList<double?> values, OtlpAggregationTemporality temporality) 270if (temporality == OtlpAggregationTemporality.Delta) 329if (histogram.AggregationTemporality == OtlpAggregationTemporality.Delta) 422var isDelta = histogramValue.AggregationTemporality == OtlpAggregationTemporality.Delta;
Components\Controls\Chart\LiveSparklinesBase.cs (1)
336if (instrument.AggregationTemporality == OtlpAggregationTemporality.Delta)
Components\Controls\Chart\MetricInstrumentDataCache.cs (1)
49var isDeltaNumber = cached.Summary.AggregationTemporality == OtlpAggregationTemporality.Delta &&
Otlp\Model\MetricValues\DimensionScope.cs (1)
87public void AddHistogramValue(HistogramDataPoint h, OtlpAggregationTemporality temporality, OtlpContext context)
Otlp\Model\MetricValues\HistogramValue.cs (8)
23internal OtlpAggregationTemporality AggregationTemporality { get; init; } 38ulong aggregationStartUnixNano, long aggregationId, OtlpAggregationTemporality aggregationTemporality) : base(startTimeUnixNano, endTimeUnixNano) 52internal static HistogramValue Create(HistogramDataPoint point, OtlpAggregationTemporality temporality, HistogramValue? previous) 59if (temporality != OtlpAggregationTemporality.Delta && previous is not null && point.TimeUnixNano < previous.EndTimeUnixNano) 68var start = temporality == OtlpAggregationTemporality.Delta && point.StartTimeUnixNano == 0 ? end : aggregationStart; 71var aggregationId = temporality == OtlpAggregationTemporality.Delta 75if (temporality != OtlpAggregationTemporality.Delta && previous is not null) 99previous.AggregationTemporality != OtlpAggregationTemporality.Delta)
Otlp\Model\OtlpInstrument.cs (1)
16public required OtlpAggregationTemporality AggregationTemporality { get; init; }
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (1)
680AggregationTemporality = (OtlpAggregationTemporality)record.AggregationTemporality,
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (15)
53WHEN p.point_type <> {HistogramPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} 83WHEN {point}.point_type <> {HistogramPointType} AND {instrument}.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} 106WHEN p.point_type <> {HistogramPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} 115TOTAL(CASE WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN ABS(p.integer_value * 1.0 * p.repeat_count) END) OVER ( 128SUM(CASE WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} AND p.rollup_integer_sum_is_safe THEN p.integer_value * p.repeat_count END) OVER ( 130TOTAL(CASE WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.integer_value * 1.0 * p.repeat_count END) OVER ( 132SUM(CASE WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.double_value * p.repeat_count END) OVER ( 148WHEN p.point_type = {LongPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} AND NOT p.rollup_integer_sum_is_safe THEN {DoublePointType} 152WHEN p.point_type = {HistogramPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.start_time_unix_nano 158WHEN p.point_type <> {HistogramPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN 1 162WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.rollup_integer_sum 166WHEN p.point_type = {LongPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} AND NOT p.rollup_integer_sum_is_safe THEN p.rollup_integer_total 167WHEN p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.rollup_double_sum 551(OtlpAggregationTemporality)point.AggregationTemporality); 628temporalities.GetValueOrDefault(dimensionId) == (int)OtlpAggregationTemporality.Delta;
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (14)
76var aggregationTemporality = MapAggregationTemporality(metric); 196OtlpAggregationTemporality temporality, 218var sameValue = temporality != OtlpAggregationTemporality.Delta && latestPointType == pointType && (pendingLatest is not null 276OtlpAggregationTemporality temporality, 582(OtlpAggregationTemporality)first.AggregationTemporality) 938private static OtlpAggregationTemporality MapAggregationTemporality(Metric metric) 942Metric.DataOneofCase.Sum => (OtlpAggregationTemporality)metric.Sum.AggregationTemporality, 943Metric.DataOneofCase.Histogram => (OtlpAggregationTemporality)metric.Histogram.AggregationTemporality, 944Metric.DataOneofCase.ExponentialHistogram => (OtlpAggregationTemporality)metric.ExponentialHistogram.AggregationTemporality, 945_ => OtlpAggregationTemporality.Unspecified 949private static bool IsSupportedAggregationTemporality(OtlpAggregationTemporality aggregationTemporality) 952OtlpAggregationTemporality.Unspecified or 953OtlpAggregationTemporality.Delta or 954OtlpAggregationTemporality.Cumulative;
Aspire.Dashboard.Components.Tests (6)
Controls\PlotlyChartTests.cs (6)
41AggregationTemporality = OtlpAggregationTemporality.Cumulative, 53dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 132AggregationTemporality = OtlpAggregationTemporality.Cumulative, 196AggregationTemporality = OtlpAggregationTemporality.Cumulative, 250AggregationTemporality = OtlpAggregationTemporality.Cumulative, 302AggregationTemporality = OtlpAggregationTemporality.Cumulative,
Aspire.Dashboard.Tests (67)
ChartDataCalculatorTests.cs (50)
43dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 44dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 363var increases = calculator.CalculateCounterIncreaseValues([frequentDimension, stoppedDimension], s_startTime, OtlpAggregationTemporality.Cumulative); 386var increases = calculator.CalculateCounterIncreaseValues([dimension], s_startTime, OtlpAggregationTemporality.Delta); 410var increases = calculator.CalculateCounterIncreaseValues([dimension], s_startTime, OtlpAggregationTemporality.Delta); 415var cached = CreateInstrumentData([dimension], OtlpInstrumentType.Sum, OtlpAggregationTemporality.Delta); 417Assert.Equal(15, calculator.CalculateCounterIncreaseValues(merged.Dimensions, s_startTime, OtlpAggregationTemporality.Delta).Sum()); 543var increases = ChartDataCalculator.CalculateCounterIncreases([double.MinValue, double.MaxValue], OtlpAggregationTemporality.Cumulative); 562var increases = calculator.CalculateCounterIncreaseValues(dimensions, s_startTime, OtlpAggregationTemporality.Cumulative); 573var increases = calculator.CalculateCounterIncreaseValues([], s_startTime, OtlpAggregationTemporality.Cumulative); 605dimension.AddHistogramValue(histogramPoint, OtlpAggregationTemporality.Cumulative, context); 642[InlineData(OtlpAggregationTemporality.Cumulative, false)] 643[InlineData(OtlpAggregationTemporality.Cumulative, true)] 644[InlineData(OtlpAggregationTemporality.Delta, false)] 645[InlineData(OtlpAggregationTemporality.Delta, true)] 646public void CalculateHistogramValues_StackedDifferences_PreservesMissingIntervals(OtlpAggregationTemporality temporality, bool sameBucket) 664var hasLastValue = temporality == OtlpAggregationTemporality.Cumulative; 681stableDimension.AddHistogramValue(CreateHistogramPoint(start, minute, 10, [10, 0, 0]), OtlpAggregationTemporality.Cumulative, context); 682changingDimension.AddHistogramValue(CreateHistogramPoint(start, minute, checked((ulong)(15 + (minute * 5))), [0, 0, checked((ulong)(15 + (minute * 5)))]), OtlpAggregationTemporality.Cumulative, context); 741dimension.AddHistogramValue(histogramPoint, OtlpAggregationTemporality.Cumulative, context); 848[InlineData(OtlpAggregationTemporality.Cumulative)] 849[InlineData(OtlpAggregationTemporality.Delta)] 850public void CalculateHistogramValues_EqualBucketLengthsWithDifferentBounds_UsesSharedBounds(OtlpAggregationTemporality temporality) 877dimension.AddHistogramValue(valid, OtlpAggregationTemporality.Cumulative, context); 888() => dimension.AddHistogramValue(invalid, OtlpAggregationTemporality.Cumulative, context)); 897dimension.AddHistogramValue(valid, OtlpAggregationTemporality.Cumulative, context); 913OtlpAggregationTemporality.Cumulative, context); 915OtlpAggregationTemporality.Cumulative, context); 921() => dimension.AddHistogramValue(stale, OtlpAggregationTemporality.Cumulative, context)); 928OtlpAggregationTemporality.Cumulative, context); 951[InlineData(OtlpAggregationTemporality.Cumulative)] 952[InlineData(OtlpAggregationTemporality.Delta)] 953public void CalculateHistogramValues_NoSharedBounds_ReportsUnavailablePercentilesAndRetainsCount(OtlpAggregationTemporality temporality) 984[InlineData(OtlpAggregationTemporality.Cumulative)] 985[InlineData(OtlpAggregationTemporality.Delta)] 986public void CalculateChartValues_UnchangedIncompatibleHistogram_DoesNotWarn(OtlpAggregationTemporality temporality) 1010OtlpAggregationTemporality.Delta, CreateContext()); 1026OtlpAggregationTemporality.Delta, CreateContext()); 1028OtlpAggregationTemporality.Delta, CreateContext()); 1051OtlpAggregationTemporality.Cumulative, context); 1053OtlpAggregationTemporality.Cumulative, context); 1072OtlpAggregationTemporality.Cumulative, context); 1075OtlpAggregationTemporality.Cumulative, context); 1125var cached = CreateInstrumentData([cachedDimension], OtlpInstrumentType.Gauge, OtlpAggregationTemporality.Cumulative); 1126var refreshed = CreateInstrumentData([refreshedDimension, newDimension], OtlpInstrumentType.Gauge, OtlpAggregationTemporality.Cumulative); 1156var cached = CreateInstrumentData([cachedDimension], OtlpInstrumentType.Gauge, OtlpAggregationTemporality.Cumulative); 1157var refreshed = CreateInstrumentData([refreshedDimension], OtlpInstrumentType.Gauge, OtlpAggregationTemporality.Cumulative); 1184CreateInstrumentData([cachedDimension], OtlpInstrumentType.Sum, OtlpAggregationTemporality.Delta), 1185CreateInstrumentData([refreshedDimension], OtlpInstrumentType.Sum, OtlpAggregationTemporality.Delta), 1216private static OtlpInstrumentData CreateInstrumentData(List<DimensionScope> dimensions, OtlpInstrumentType type, OtlpAggregationTemporality temporality)
HistogramAllocationTests.cs (3)
19var previous = HistogramValue.Create(point, OtlpAggregationTemporality.Cumulative, previous: null); 24HistogramValue.Create(point, OtlpAggregationTemporality.Cumulative, previous); 32current = HistogramValue.Create(point, OtlpAggregationTemporality.Cumulative, previous);
Model\DefaultInstrumentUnitResolverTests.cs (1)
36AggregationTemporality = OtlpAggregationTemporality.Cumulative,
Model\MetricPinStoreTests.cs (1)
171AggregationTemporality = OtlpAggregationTemporality.Cumulative,
SparklinePathTests.cs (2)
102var increases = ChartDataCalculator.CalculateCounterIncreases([null, 10, 15, 15, 3, null, 8, 9], OtlpAggregationTemporality.Cumulative); 110var increases = ChartDataCalculator.CalculateCounterIncreases([1, null, 2], OtlpAggregationTemporality.Delta);
TelemetryRepositoryTests\HistogramTests.cs (6)
911var value = HistogramValue.Create(point, OtlpAggregationTemporality.Delta, previous: null); 1324var previous = HistogramValue.Create(first, OtlpAggregationTemporality.Cumulative, previous: null); 1325var current = HistogramValue.Create(reset, OtlpAggregationTemporality.Cumulative, previous); 1463var firstValue = HistogramValue.Create(first, OtlpAggregationTemporality.Cumulative, previous: null); 1464var resetValue = HistogramValue.Create(reset, OtlpAggregationTemporality.Cumulative, firstValue); 1465var nextResetValue = HistogramValue.Create(nextReset, OtlpAggregationTemporality.Cumulative, resetValue);
TelemetryRepositoryTests\MetricsTests.cs (4)
73var increases = calculator.CalculateCounterIncreaseValues(instrument.Dimensions, new DateTimeOffset(windowEnd, TimeSpan.Zero), OtlpAggregationTemporality.Delta); 262var increases = calculator.CalculateCounterIncreaseValues(instrument.Dimensions, new DateTimeOffset(windowEnd, TimeSpan.Zero), OtlpAggregationTemporality.Delta); 283var increases = calculator.CalculateCounterIncreaseValues(instrument.Dimensions, new DateTimeOffset(windowEnd, TimeSpan.Zero), OtlpAggregationTemporality.Delta); 359var increases = calculator.CalculateCounterIncreaseValues(instrument.Dimensions, new DateTimeOffset(windowEnd, TimeSpan.Zero), OtlpAggregationTemporality.Delta);