rrd

type DataOutput interface {
	DumpComment(comment string)
	DumpString(field, value string)
	DumpDouble(field string, value float64)
	DumpUnsignedLong(field string, value uint64)
	DumpTime(field string, value time.Time)
	DumpDuration(field string, value time.Duration)
	DumpSubFields(field string, subDump func(DataOutput) error)
	Finalize() error
}

type Datasource interface {
	GetName() string
	GetLastValue() string
	CalculatePdpPrep(newValue string, interval float64) (float64, error)
	UpdatePdp(pdpValue, interval float64)
	ProcessPdp(pdpValue float64, elapsed ElapsedPdpSteps, step time.Duration) float64
	DumpTo(dumper DataOutput) error
}

type DatasourceAbsolute struct {
	DatasourceAbstract
}

type DatasourceAbstract struct {
	Name            string  `ds:"name"`
	Heartbeat       uint64  `ds:"param0"`
	Min             float64 `ds:"param1"`
	Max             float64 `ds:"param2"`
	LastValue       string  `pdp:"lastValue"`
	UnknownSecCount uint64  `pdp:"0"`
	PdpValue        float64 `pdp:"1"`
}

type DatasourceCompute struct {
	Name      string
	LastValue string
}

type DatasourceCounter struct {
	DatasourceAbstract
}

type DatasourceDCounter struct {
	DatasourceAbstract
}

type DatasourceDDerive struct {
	DatasourceAbstract
}

type DatasourceDerive struct {
	DatasourceAbstract
}

type DatasourceGauge struct {
	DatasourceAbstract
}

type ElapsedPdpSteps struct {
	Interval     float64
	Steps        uint64
	PreInt       float64
	PostInt      float64
	ProcPdpCount uint64
}

type Rra interface {
	GetRowCount() uint64
	GetPdpPerRow() uint64
	GetPrimaryValues() []float64
	GetSecondaryValues() []float64
	UpdateCdpPreps(pdpTemp []float64, elapsed ElapsedPdpSteps) uint64
	UpdateAberantCdp(pdpTemp []float64, first bool)
	// DumpTo dumps the content of the archive to a data dumper.
	DumpTo(rrdStore Store, dumper DataOutput)
}

type RraAbstract struct {
	Index     int
	RowCount  uint64 `rra:"rowCount"`
	PdpPerRow uint64 `rra:"pdpPerRow"`
}

type RraAbstractGeneric struct {
	RraAbstract
	XFilesFactor            float64             `rra:"param0"`
	CpdPreps                []RraCpdPrepGeneric `rra:"cpdPreps"`
	UpdateAberantCdpFunc    func(pdpTemp float64, cpdPrep *RraCpdPrepGeneric)
	InitializeCdpFunc       func(pdpTemp float64, pdpPerRow, startPdpOffset uint64, cpdPrep *RraCpdPrepGeneric)
	InitializeCarryOverFunc func(pdpTemp float64, elapsedPdpSt, pdpPerRow, startPdpOffset uint64, cpdPrep *RraCpdPrepGeneric) float64
	CalculateCdpValueFunc   func(pdpTemp float64, elapsedPdpSt uint64, cpdPrep *RraCpdPrepGeneric) float64
}

type RraAverage struct {
	RraAbstractGeneric
}

type RraCpdPrepBase struct {
	PrimaryValue   float64 `cdp:"8"`
	SecondaryValue float64 `cdp:"9"`
}

type RraCpdPrepFailures struct {
	RraCpdPrepBase
	History []byte `cdp:"raw"`
}

type RraCpdPrepGeneric struct {
	RraCpdPrepBase
	Value             float64 `cdp:"0"`
	UnknownDatapoints uint64  `cdp:"1"`
}

type RraCpdPrepHwPredict struct {
	RraCpdPrepBase
	Intercept     float64 `cdp:"2"`
	LastIntercept float64 `cdp:"3"`
	Slope         float64 `cdp:"4"`
	LastSlope     float64 `cdp:"5"`
	NullCount     uint64  `cdp:"6"`
	LastNullCount uint64  `cdp:"7"`
}

type RraCpdPrepSeasonal struct {
	RraCpdPrepBase
	Seasonal     float64 `cdp:"2"`
	LastSeasonal float64 `cdp:"3"`
	InitFlag     uint64  `cdp:"6"`
}

type RraDevPredict struct {
	RraAbstract
	DependentRraIdx uint64           `rra:"param3"`
	CpdPreps        []RraCpdPrepBase `rra:"cpdPreps"`
}

type RraDevSeasonal struct {
	RraSeasonal
}

type RraHwFailures struct {
	RraAbstract
	DeltaPos         float64              `rra:"param1"`
	DeltaNeg         float64              `rra:"param2"`
	WindowLen        uint64               `rra:"param4"`
	FailureThreshold uint64               `rra:"param5"`
	DependentRraIdx  uint64               `rra:"param3"`
	CpdPreps         []RraCpdPrepFailures `rra:"cpdPreps"`
}

type RraHwPredict struct {
	RraAbstract
	Alpha           float64               `rra:"param1"`
	Beta            float64               `rra:"param2"`
	DependentRraIdx uint64                `rra:"param3"`
	CpdPreps        []RraCpdPrepHwPredict `rra:"cpdPreps"`
}

type RraLast struct {
	RraAbstractGeneric
}

type RraMax struct {
	RraAbstractGeneric
}

type RraMin struct {
	RraAbstractGeneric
}

type RraRow struct {
	Timestamp time.Time
	Values    []float64
}

type RraRowIterator interface {
	Next() bool
	Value() (*RraRow, error)
	Close()
}

type RraSeasonal struct {
	RraAbstract
	Gamma           float64              `rra:"param1"`
	SmoothIdx       uint64               `rra:"param4"`
	DependentRraIdx uint64               `rra:"param3"`
	CpdPreps        []RraCpdPrepSeasonal `rra:"cpdPreps"`
}

type Rrd struct {
	Version     uint16
	Store       Store
	Step        time.Duration
	LastUpdate  time.Time
	Datasources []Datasource
	Rras        []Rra
}

type Store interface {
	Version() uint16
	DatasourceTypes() []string
	RraTypes() []string
	LastUpdate() time.Time
	Step() time.Duration

	ReadDatasourceParams(index int, params interface{}) error
	StoreDatasourceParams(index int, params interface{}) error
	ReadRraParams(index int, params interface{}) error
	StoreRraParams(index int, params interface{}) error
	StoreLastUpdate(lastUpdate time.Time) error
	StoreRraPtrs() error

	RowIterator(rraIndex int) (RraRowIterator, error)
	StoreRow(rraIndex int, row []float64) error
	Close()
}