Implement timeShift
This commit is contained in:
@@ -1,5 +1,7 @@
|
||||
package timeseries
|
||||
|
||||
import "time"
|
||||
|
||||
func TransformScale(factor float64) TransformFunc {
|
||||
return func(point TimePoint) TimePoint {
|
||||
return transformScale(point, factor)
|
||||
@@ -12,6 +14,12 @@ func TransformOffset(offset float64) TransformFunc {
|
||||
}
|
||||
}
|
||||
|
||||
func TransformShiftTime(interval time.Duration) TransformFunc {
|
||||
return func(point TimePoint) TimePoint {
|
||||
return transformShiftTime(point, interval)
|
||||
}
|
||||
}
|
||||
|
||||
func transformScale(point TimePoint, factor float64) TimePoint {
|
||||
if point.Value != nil {
|
||||
newValue := *point.Value * factor
|
||||
@@ -27,3 +35,9 @@ func transformOffset(point TimePoint, offset float64) TimePoint {
|
||||
}
|
||||
return point
|
||||
}
|
||||
|
||||
func transformShiftTime(point TimePoint, interval time.Duration) TimePoint {
|
||||
shiftedTime := point.Time.Add(interval)
|
||||
point.Time = shiftedTime
|
||||
return point
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user