timeseries

Documentation

Index

• Variables
• type Record
• type TimeSeries
  • func NewTimeSeries(name string, retention int64) *TimeSeries
  • func (ts *TimeSeries) AddPoint(value float64) Record
  • func (ts *TimeSeries) AddRecord(record *Record)
  • func (ts *TimeSeries) Average() (float64, error)
  • func (ts *TimeSeries) AverageInterval(interval_ms int64) ([]Record, error)
  • func (ts *TimeSeries) Find(timestamp int64) (*Record, int)
  • func (ts *TimeSeries) First() (*Record, error)
  • func (ts *TimeSeries) Last() (*Record, error)
  • func (ts *TimeSeries) Len() int
  • func (ts *TimeSeries) Max() (*Record, error)
  • func (ts *TimeSeries) Min() (*Record, error)
  • func (ts *TimeSeries) Range(lo, hi int64) (*TimeSeries, error)

Variables

var (
	EmptyTimeSeriesErr = errors.New("no records in timeseries")
)

Types

type Record

type Record struct {
	Timestamp int64
	Value     float64
}

Record represents a point in the timeseries, currently holds only a float value

type TimeSeries

type TimeSeries struct {
	Name      string
	Retention int64

	Records []*Record
	// contains filtered or unexported fields
}

TimeSeries represents a time series, essentially an append-only log of point values in time

func NewTimeSeries

func NewTimeSeries(name string, retention int64) *TimeSeries

NewTestSeries create a new TimeSeries by accepting a name and a retention value

func (*TimeSeries) AddPoint

func (ts *TimeSeries) AddPoint(value float64) Record

AddPoint add a new point to an existing TimeSeries

func (*TimeSeries) AddRecord

func (ts *TimeSeries) AddRecord(record *Record)

func (*TimeSeries) Average

func (ts *TimeSeries) Average() (float64, error)

func (*TimeSeries) AverageInterval

func (ts *TimeSeries) AverageInterval(interval_ms int64) ([]Record, error)

func (*TimeSeries) Find

func (ts *TimeSeries) Find(timestamp int64) (*Record, int)

func (*TimeSeries) First

func (ts *TimeSeries) First() (*Record, error)

func (*TimeSeries) Last

func (ts *TimeSeries) Last() (*Record, error)

func (*TimeSeries) Len

func (ts *TimeSeries) Len() int

func (*TimeSeries) Max

func (ts *TimeSeries) Max() (*Record, error)

func (*TimeSeries) Min

func (ts *TimeSeries) Min() (*Record, error)

func (*TimeSeries) Range

func (ts *TimeSeries) Range(lo, hi int64) (*TimeSeries, error)