76 references to OtlpAggregationTemporality
Aspire.Dashboard (27)
Components\Controls\Chart\ChartDataCalculator.cs (2)
176if (histogram.AggregationTemporality == OtlpAggregationTemporality.Delta) 264var isDelta = histogramValue.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)
676AggregationTemporality = (OtlpAggregationTemporality)record.AggregationTemporality,
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (2)
94WHEN p.point_type = {HistogramPointType} AND p.aggregation_temporality = {(int)OtlpAggregationTemporality.Delta} THEN p.start_time_unix_nano 478(OtlpAggregationTemporality)point.AggregationTemporality);
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (12)
76var aggregationTemporality = MapAggregationTemporality(metric); 272OtlpAggregationTemporality temporality, 578(OtlpAggregationTemporality)first.AggregationTemporality) 934private static OtlpAggregationTemporality MapAggregationTemporality(Metric metric) 938Metric.DataOneofCase.Sum => (OtlpAggregationTemporality)metric.Sum.AggregationTemporality, 939Metric.DataOneofCase.Histogram => (OtlpAggregationTemporality)metric.Histogram.AggregationTemporality, 940Metric.DataOneofCase.ExponentialHistogram => (OtlpAggregationTemporality)metric.ExponentialHistogram.AggregationTemporality, 941_ => OtlpAggregationTemporality.Unspecified 945private static bool IsSupportedAggregationTemporality(OtlpAggregationTemporality aggregationTemporality) 948OtlpAggregationTemporality.Unspecified or 949OtlpAggregationTemporality.Delta or 950OtlpAggregationTemporality.Cumulative;
Aspire.Dashboard.Components.Tests (3)
Controls\PlotlyChartTests.cs (3)
41AggregationTemporality = OtlpAggregationTemporality.Cumulative, 52dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 131AggregationTemporality = OtlpAggregationTemporality.Cumulative,
Aspire.Dashboard.Tests (46)
ChartDataCalculatorTests.cs (36)
43dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 44dimension.AddHistogramValue(point, OtlpAggregationTemporality.Cumulative, context); 360dimension.AddHistogramValue(histogramPoint, OtlpAggregationTemporality.Cumulative, context); 397[InlineData(OtlpAggregationTemporality.Cumulative, false)] 398[InlineData(OtlpAggregationTemporality.Cumulative, true)] 399[InlineData(OtlpAggregationTemporality.Delta, false)] 400[InlineData(OtlpAggregationTemporality.Delta, true)] 401public void CalculateHistogramValues_StackedDifferences_PreservesMissingIntervals(OtlpAggregationTemporality temporality, bool sameBucket) 419var hasLastValue = temporality == OtlpAggregationTemporality.Cumulative; 436stableDimension.AddHistogramValue(CreateHistogramPoint(start, minute, 10, [10, 0, 0]), OtlpAggregationTemporality.Cumulative, context); 437changingDimension.AddHistogramValue(CreateHistogramPoint(start, minute, checked((ulong)(15 + (minute * 5))), [0, 0, checked((ulong)(15 + (minute * 5)))]), OtlpAggregationTemporality.Cumulative, context); 496dimension.AddHistogramValue(histogramPoint, OtlpAggregationTemporality.Cumulative, context); 603[InlineData(OtlpAggregationTemporality.Cumulative)] 604[InlineData(OtlpAggregationTemporality.Delta)] 605public void CalculateHistogramValues_EqualBucketLengthsWithDifferentBounds_UsesSharedBounds(OtlpAggregationTemporality temporality) 632dimension.AddHistogramValue(valid, OtlpAggregationTemporality.Cumulative, context); 643() => dimension.AddHistogramValue(invalid, OtlpAggregationTemporality.Cumulative, context)); 652dimension.AddHistogramValue(valid, OtlpAggregationTemporality.Cumulative, context); 668OtlpAggregationTemporality.Cumulative, context); 670OtlpAggregationTemporality.Cumulative, context); 676() => dimension.AddHistogramValue(stale, OtlpAggregationTemporality.Cumulative, context)); 683OtlpAggregationTemporality.Cumulative, context); 706[InlineData(OtlpAggregationTemporality.Cumulative)] 707[InlineData(OtlpAggregationTemporality.Delta)] 708public void CalculateHistogramValues_NoSharedBounds_ReportsUnavailablePercentilesAndRetainsCount(OtlpAggregationTemporality temporality) 739[InlineData(OtlpAggregationTemporality.Cumulative)] 740[InlineData(OtlpAggregationTemporality.Delta)] 741public void CalculateChartValues_UnchangedIncompatibleHistogram_DoesNotWarn(OtlpAggregationTemporality temporality) 765OtlpAggregationTemporality.Delta, CreateContext()); 781OtlpAggregationTemporality.Delta, CreateContext()); 783OtlpAggregationTemporality.Delta, CreateContext()); 806OtlpAggregationTemporality.Cumulative, context); 808OtlpAggregationTemporality.Cumulative, context); 827OtlpAggregationTemporality.Cumulative, context); 830OtlpAggregationTemporality.Cumulative, context); 959AggregationTemporality = OtlpAggregationTemporality.Cumulative,
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,
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);