Documentation ¶
Index ¶
- func AggAvg(points []TimePoint) *float64
- func AggCount(points []TimePoint) *float64
- func AggFirst(points []TimePoint) *float64
- func AggLast(points []TimePoint) *float64
- func AggMax(points []TimePoint) *float64
- func AggMedian(points []TimePoint) *float64
- func AggMin(points []TimePoint) *float64
- func AggSum(points []TimePoint) *float64
- type AggFunc
- type AggregationFunc
- type TimePoint
- type TimeSeries
- func (ts TimeSeries) Align(interval time.Duration) TimeSeries
- func (ts TimeSeries) Delta() TimeSeries
- func (ts TimeSeries) DetectInterval() time.Duration
- func (ts TimeSeries) ExponentialMovingAverage(an float64) TimeSeries
- func (ts TimeSeries) FillTrendWithNulls() TimeSeries
- func (ts TimeSeries) GroupBy(interval time.Duration, aggFunc AggFunc) TimeSeries
- func (ts TimeSeries) GroupByRange(aggFunc AggFunc) TimeSeries
- func (ts *TimeSeries) Len() int
- func (ts TimeSeries) Rate() TimeSeries
- func (ts TimeSeries) SimpleMovingAverage(n int) TimeSeries
- func (ts TimeSeries) Sort()
- func (ts TimeSeries) Transform(transformFunc TransformFunc) TimeSeries
- type TimeSeriesData
- func AggregateBy(series []*TimeSeriesData, interval time.Duration, aggFunc AggFunc) *TimeSeriesData
- func AggregateByRange(series []*TimeSeriesData, aggFunc AggFunc) *TimeSeriesData
- func Filter(series []*TimeSeriesData, n int, order string, aggFunc AggFunc) []*TimeSeriesData
- func NewTimeSeriesData() *TimeSeriesData
- func PrepareForStack(series []*TimeSeriesData) []*TimeSeriesData
- func SortBy(series []*TimeSeriesData, order string, aggFunc AggFunc) []*TimeSeriesData
- func SortByItem(series []*TimeSeriesData) []*TimeSeriesData
- func SortByName(series []*TimeSeriesData, order string) []*TimeSeriesData
- func SumSeries(series []*TimeSeriesData) *TimeSeriesData
- type TimeSeriesMeta
- type TransformFunc
- func TransformNull(nullValue float64) TransformFunc
- func TransformOffset(offset float64) TransformFunc
- func TransformRemoveAboveValue(threshold float64) TransformFunc
- func TransformRemoveBelowValue(threshold float64) TransformFunc
- func TransformScale(factor float64) TransformFunc
- func TransformShiftTime(interval time.Duration) TransformFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AggregationFunc ¶
func AggPercentile ¶
func AggPercentile(n float64) AggregationFunc
type TimePoint ¶
func (*TimePoint) GetTimeFrame ¶
Gets point timestamp rounded according to provided interval.
func (*TimePoint) UnmarshalJSON ¶
type TimeSeries ¶
type TimeSeries []TimePoint
func NewTimeSeries ¶
func NewTimeSeries() TimeSeries
func (TimeSeries) Align ¶
func (ts TimeSeries) Align(interval time.Duration) TimeSeries
Aligns point's time stamps according to provided interval.
func (TimeSeries) Delta ¶
func (ts TimeSeries) Delta() TimeSeries
func (TimeSeries) DetectInterval ¶
func (ts TimeSeries) DetectInterval() time.Duration
Detects interval between data points in milliseconds based on median delta between points.
func (TimeSeries) ExponentialMovingAverage ¶
func (ts TimeSeries) ExponentialMovingAverage(an float64) TimeSeries
func (TimeSeries) FillTrendWithNulls ¶
func (ts TimeSeries) FillTrendWithNulls() TimeSeries
Fill missing points in trend by null values
func (TimeSeries) GroupBy ¶
func (ts TimeSeries) GroupBy(interval time.Duration, aggFunc AggFunc) TimeSeries
GroupBy groups points in given interval by applying provided `aggFunc`. Source time series should be sorted by time.
func (TimeSeries) GroupByRange ¶
func (ts TimeSeries) GroupByRange(aggFunc AggFunc) TimeSeries
func (*TimeSeries) Len ¶
func (ts *TimeSeries) Len() int
func (TimeSeries) Rate ¶
func (ts TimeSeries) Rate() TimeSeries
func (TimeSeries) SimpleMovingAverage ¶
func (ts TimeSeries) SimpleMovingAverage(n int) TimeSeries
func (TimeSeries) Sort ¶
func (ts TimeSeries) Sort()
func (TimeSeries) Transform ¶
func (ts TimeSeries) Transform(transformFunc TransformFunc) TimeSeries
type TimeSeriesData ¶
type TimeSeriesData struct { TS TimeSeries Meta TimeSeriesMeta }
func AggregateBy ¶
func AggregateBy(series []*TimeSeriesData, interval time.Duration, aggFunc AggFunc) *TimeSeriesData
func AggregateByRange ¶
func AggregateByRange(series []*TimeSeriesData, aggFunc AggFunc) *TimeSeriesData
func Filter ¶
func Filter(series []*TimeSeriesData, n int, order string, aggFunc AggFunc) []*TimeSeriesData
func NewTimeSeriesData ¶
func NewTimeSeriesData() *TimeSeriesData
func PrepareForStack ¶
func PrepareForStack(series []*TimeSeriesData) []*TimeSeriesData
PrepareForStack performs series interpolation to make series consist of the points with same time stamps
func SortBy ¶
func SortBy(series []*TimeSeriesData, order string, aggFunc AggFunc) []*TimeSeriesData
SortBy sorts series by value calculated with provided aggFunc in given order
func SortByItem ¶
func SortByItem(series []*TimeSeriesData) []*TimeSeriesData
func SortByName ¶
func SortByName(series []*TimeSeriesData, order string) []*TimeSeriesData
func SumSeries ¶
func SumSeries(series []*TimeSeriesData) *TimeSeriesData
func (*TimeSeriesData) Add ¶
func (tsd *TimeSeriesData) Add(point TimePoint) *TimeSeriesData
func (TimeSeriesData) Len ¶
func (tsd TimeSeriesData) Len() int
type TimeSeriesMeta ¶
type TransformFunc ¶
func TransformNull ¶
func TransformNull(nullValue float64) TransformFunc
func TransformOffset ¶
func TransformOffset(offset float64) TransformFunc
func TransformRemoveAboveValue ¶
func TransformRemoveAboveValue(threshold float64) TransformFunc
func TransformRemoveBelowValue ¶
func TransformRemoveBelowValue(threshold float64) TransformFunc
func TransformScale ¶
func TransformScale(factor float64) TransformFunc
func TransformShiftTime ¶
func TransformShiftTime(interval time.Duration) TransformFunc
Click to show internal directories.
Click to hide internal directories.