timeseries

Documentation

Index

• type ReverseIterator
  • func (it *ReverseIterator[T]) Next() bool
  • func (it *ReverseIterator[T]) Value() TimeSeriesSample[T]
• type TimeSeries
  • func NewTimeSeries[T number](params TimeSeriesParams) *TimeSeries[T]
  • func (t *TimeSeries[T]) AddSample(val T)
  • func (t *TimeSeries[T]) AddSampleAt(val T, at time.Time)
  • func (t *TimeSeries[T]) Back() TimeSeriesSample[T]
  • func (t *TimeSeries[T]) ClearSamples()
  • func (t *TimeSeries[T]) CommitActiveSample()
  • func (t *TimeSeries[T]) CommitActiveSampleAt(at time.Time)
  • func (t *TimeSeries[T]) CurrentRun(threshold T, op TimeSeriesCompareOp) time.Duration
  • func (t *TimeSeries[T]) GetSamples() []TimeSeriesSample[T]
  • func (t *TimeSeries[T]) GetSamplesAfter(at time.Time) []TimeSeriesSample[T]
  • func (t *TimeSeries[T]) HasSamplesAfter(at time.Time) bool
  • func (t *TimeSeries[T]) KendallsTau(numSamplesToUse int) (float64, error)
  • func (t *TimeSeries[T]) LinearExtrapolateTo(numSamplesToUse int, after time.Duration) (float64, error)
  • func (t *TimeSeries[T]) Max() T
  • func (t *TimeSeries[T]) Min() T
  • func (t *TimeSeries[T]) OnlineAverage() float64
  • func (t *TimeSeries[T]) OnlineStdDev() float64
  • func (t *TimeSeries[T]) OnlineVariance() float64
  • func (t *TimeSeries[T]) ReverseIterateSamplesAfter(at time.Time) ReverseIterator[T]
  • func (t *TimeSeries[T]) Slope() float64
  • func (t *TimeSeries[T]) Sum() float64
  • func (t *TimeSeries[T]) UpdateSample(val T)
  • func (t *TimeSeries[T]) ZScore(val T) float64
• type TimeSeriesCompareOp
  • func (t TimeSeriesCompareOp) String() string
• type TimeSeriesParams
• type TimeSeriesSample
• type TimeSeriesUpdateOp
  • func (t TimeSeriesUpdateOp) String() string

Types

type ReverseIterator

type ReverseIterator[T number] struct {
	// contains filtered or unexported fields
}

func (*ReverseIterator[T]) Next

func (it *ReverseIterator[T]) Next() bool

func (*ReverseIterator[T]) Value

func (it *ReverseIterator[T]) Value() TimeSeriesSample[T]

type TimeSeries

type TimeSeries[T number] struct {
	// contains filtered or unexported fields
}

func NewTimeSeries

func NewTimeSeries[T number](params TimeSeriesParams) *TimeSeries[T]

func (*TimeSeries[T]) AddSample

func (t *TimeSeries[T]) AddSample(val T)

func (*TimeSeries[T]) AddSampleAt

func (t *TimeSeries[T]) AddSampleAt(val T, at time.Time)

func (*TimeSeries[T]) Back

func (t *TimeSeries[T]) Back() TimeSeriesSample[T]

func (*TimeSeries[T]) ClearSamples

func (t *TimeSeries[T]) ClearSamples()

func (*TimeSeries[T]) CommitActiveSample

func (t *TimeSeries[T]) CommitActiveSample()

func (*TimeSeries[T]) CommitActiveSampleAt

func (t *TimeSeries[T]) CommitActiveSampleAt(at time.Time)

func (*TimeSeries[T]) CurrentRun

func (t *TimeSeries[T]) CurrentRun(threshold T, op TimeSeriesCompareOp) time.Duration

func (*TimeSeries[T]) GetSamples

func (t *TimeSeries[T]) GetSamples() []TimeSeriesSample[T]

func (*TimeSeries[T]) GetSamplesAfter

func (t *TimeSeries[T]) GetSamplesAfter(at time.Time) []TimeSeriesSample[T]

func (*TimeSeries[T]) HasSamplesAfter

func (t *TimeSeries[T]) HasSamplesAfter(at time.Time) bool

func (*TimeSeries[T]) KendallsTau

func (t *TimeSeries[T]) KendallsTau(numSamplesToUse int) (float64, error)

func (*TimeSeries[T]) LinearExtrapolateTo

func (t *TimeSeries[T]) LinearExtrapolateTo(numSamplesToUse int, after time.Duration) (float64, error)

func (*TimeSeries[T]) Max

func (t *TimeSeries[T]) Max() T

func (*TimeSeries[T]) Min

func (t *TimeSeries[T]) Min() T

func (*TimeSeries[T]) OnlineAverage

func (t *TimeSeries[T]) OnlineAverage() float64

func (*TimeSeries[T]) OnlineStdDev

func (t *TimeSeries[T]) OnlineStdDev() float64

func (*TimeSeries[T]) OnlineVariance

func (t *TimeSeries[T]) OnlineVariance() float64

func (*TimeSeries[T]) ReverseIterateSamplesAfter

func (t *TimeSeries[T]) ReverseIterateSamplesAfter(at time.Time) ReverseIterator[T]

func (*TimeSeries[T]) Slope

func (t *TimeSeries[T]) Slope() float64

func (*TimeSeries[T]) Sum

func (t *TimeSeries[T]) Sum() float64

func (*TimeSeries[T]) UpdateSample

func (t *TimeSeries[T]) UpdateSample(val T)

func (*TimeSeries[T]) ZScore

func (t *TimeSeries[T]) ZScore(val T) float64

type TimeSeriesCompareOp

type TimeSeriesCompareOp int

const (
	TimeSeriesCompareOpEQ TimeSeriesCompareOp = iota
	TimeSeriesCompareOpNE
	TimeSeriesCompareOpGT
	TimeSeriesCompareOpGTE
	TimeSeriesCompareOpLT
	TimeSeriesCompareOpLTE
)

func (TimeSeriesCompareOp) String

func (t TimeSeriesCompareOp) String() string

type TimeSeriesParams

type TimeSeriesParams struct {
	UpdateOp         TimeSeriesUpdateOp
	Window           time.Duration
	CollapseDuration time.Duration
}

type TimeSeriesSample

type TimeSeriesSample[T number] struct {
	Value T
	At    time.Time
}

type TimeSeriesUpdateOp

type TimeSeriesUpdateOp int

const (
	TimeSeriesUpdateOpAdd TimeSeriesUpdateOp = iota
	TimeSeriesUpdateOpMax
	TimeSeriesUpdateOpLatest
)

func (TimeSeriesUpdateOp) String

func (t TimeSeriesUpdateOp) String() string