Misthios/grafana-zabbix
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Alignment: fix interpolation

Browse Source
This commit is contained in:
Alexander Zobnin
2021-09-23 14:03:16 +03:00
parent 1f98dc7f4c
commit 59ce70df4b
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/timeseries/align.go
View File

@@ -22,17 +22,19 @@ func (ts TimeSeries) Align(interval time.Duration) TimeSeries {
pointFrameTs = point.GetTimeFrame(interval) pointFrameTs = point.GetTimeFrame(interval)
if pointFrameTs.After(frameTs) { if pointFrameTs.After(frameTs) {
pointsToAdd := make([]TimePoint, 0) nullPointsToAdd := make([]TimePoint, 0)
for frameTs.Before(pointFrameTs) { for frameTs.Before(pointFrameTs) {
pointsToAdd = append(pointsToAdd, TimePoint{Time: frameTs, Value: nil}) nullPointsToAdd = append(nullPointsToAdd, TimePoint{Time: frameTs, Value: nil})
frameTs = frameTs.Add(interval) frameTs = frameTs.Add(interval)
} }
if len(pointsToAdd) > 1 { if len(nullPointsToAdd) > 1 {
alignedTs = append(alignedTs, pointsToAdd...) alignedTs = append(alignedTs, nullPointsToAdd...)
} else if len(pointsToAdd) == 1 && i < ts.Len()-1 { } else if len(nullPointsToAdd) == 1 && i < ts.Len()-1 {
// In case of 1 point gap, insert interpolated value to prevent unnecessary gaps // In case of 1 point gap, insert interpolated value to prevent unnecessary gaps
interpolatedPoint := pointsToAdd[0] interpolatedPoint := nullPointsToAdd[0]
pointValue := linearInterpolation(interpolatedPoint.Time, ts[i], ts[i+1]) left := alignedTs[len(alignedTs)-1]
right := TimePoint{Time: pointFrameTs, Value: point.Value}
pointValue := linearInterpolation(interpolatedPoint.Time, left, right)
interpolatedPoint.Value = &pointValue interpolatedPoint.Value = &pointValue
alignedTs = append(alignedTs, interpolatedPoint) alignedTs = append(alignedTs, interpolatedPoint)
} }