47 references to Delta
Aspire.Dashboard (27)
Components\Controls\Chart\ChartDataCalculator.cs (4)
161if (temporality == OtlpAggregationTemporality.Delta) 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\HistogramValue.cs (5)
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\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (14)
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 628temporalities.GetValueOrDefault(dimensionId) == (int)OtlpAggregationTemporality.Delta;
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (2)
218var sameValue = temporality != OtlpAggregationTemporality.Delta && latestPointType == pointType && (pendingLatest is not null 953OtlpAggregationTemporality.Delta or
Aspire.Dashboard.Tests (20)
ChartDataCalculatorTests.cs (14)
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()); 644[InlineData(OtlpAggregationTemporality.Delta, false)] 645[InlineData(OtlpAggregationTemporality.Delta, true)] 849[InlineData(OtlpAggregationTemporality.Delta)] 952[InlineData(OtlpAggregationTemporality.Delta)] 985[InlineData(OtlpAggregationTemporality.Delta)] 1010OtlpAggregationTemporality.Delta, CreateContext()); 1026OtlpAggregationTemporality.Delta, CreateContext()); 1028OtlpAggregationTemporality.Delta, CreateContext()); 1184CreateInstrumentData([cachedDimension], OtlpInstrumentType.Sum, OtlpAggregationTemporality.Delta), 1185CreateInstrumentData([refreshedDimension], OtlpInstrumentType.Sum, OtlpAggregationTemporality.Delta),
SparklinePathTests.cs (1)
110var increases = ChartDataCalculator.CalculateCounterIncreases([1, null, 2], OtlpAggregationTemporality.Delta);
TelemetryRepositoryTests\HistogramTests.cs (1)
911var value = HistogramValue.Create(point, OtlpAggregationTemporality.Delta, previous: null);
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);