db

type DB interface {
	Init() (err error)
	WriteRow(wRecord WriteRecord, src string) (rowKey string, err error)
	ReadRow(req RowRequest) (returnVal *ReadRecord, err error)
	ReadRows(req RowRangeRequests) (returnVal *DataTable, err error)
	DeleteRow(rowKey string) (err error)
	WriteDir(si SourceInfoUncomp, src string) (err error)
	ReadDir(req DirectorySearchRequest) (result SourceInfoUncomp, err error)
	DeleteDir(path, file string) (err error)
}

type DataTable struct {
	ColumnNames        []string      `json:"aggregatesColumnNames,omitempty"`
	Data               []*[]*float64 `json:"aggregates,omitempty"`
	IdColumn           []string      `json:"ids,omitempty"`
	ConfigsColumnNames []string      `json:"configsColumnNames,omitempty"`
	Configs            []*[]*string  `json:"configs,omitempty"`
	Timestamps         []*float64    `json:"timestamps,omitempty"`
}

type DirectorySearchRequest struct {
	Prefix                  string
	FileRestrict            string
	ReturnMetrics           bool
	ReturnUnits             bool
	ReturnSelectForDefaults bool
	DefaultsOnly            bool
	DirPrefixMatch          bool
	FilePrefixMatch         bool
}

type FilteredSource struct {
	Source           string
	MetricsFilter    map[string]bool
	AggregatesFilter map[string]bool
	ConfigsFilter    map[string]string // Setting key only will separate into different configs.
}

type PointsRecord struct {
	Name       string    `json:"name,omitempty"`
	Timestamps []int64   `json:"timestamps,omitempty"`
	Data       []float64 `json:"data,omitempty"`
}

type Qualifier struct {
	StartTimestamp int64
	EndTimestamp   int64
	MaxResults     int

	SetAggregateIfMissing bool

	EqualX       bool
	SortByColumn string
	SortByConfig string // Overrides SortByColumn if both set.
	NoTimeColumn bool

	ReturnIds          bool
	ReturnConfigs      bool
	NoReturnAggregates bool
}

type ReadRecord struct {
	Source                *string           `json:"source,omitempty"`
	RecordTimestamp       *int64            `json:"recordTimestamp,omitempty"`
	PointsColumnNames     []string          `json:"pointsColumnNames,omitempty"`
	Points                []*[]*float64     `json:"points,omitempty"`
	PointsDataType        string            `json:"pointsDataType,omitempty"`
	AggregatesColumnNames []string          `json:"aggregatesColumnNames,omitempty"`
	Aggregates            []*float64        `json:"aggregates,omitempty"`
	AggregatesDataType    string            `json:"aggregatesDataType,omitempty"`
	ConfigPairs           map[string]string `json:"configPairs,omitempty"`
	Id                    string            `json:"id,omitempty"`
}

type RowRangeRequests struct {
	FilteredSources []FilteredSource
	Qualifier
}

type RowRequest struct {
	Id                 string
	NoReturnAggregates bool
}

type SourceInfoUncomp struct {
	Names             []string `json:"names,omitempty"`
	Units             []string `json:"units,omitempty"`
	SelectForDefaults []bool   `json:"selectForDefaults,omitempty"`
}

type StringSlice []string

type WriteRecord struct {
	RecordTimestamp       *int64            `json:"recordTimestamp,omitempty"`
	Points                []PointsRecord    `json:"points,omitempty"`
	PointsDataType        string            `json:"pointsDataType,omitempty"`
	AggregatesColumnNames []string          `json:"aggregatesColumnNames,omitempty"`
	Aggregates            []*float64        `json:"aggregates,omitempty"`
	AggregatesDataType    string            `json:"aggregatesDataType,omitempty"`
	ConfigPairs           map[string]string `json:"configPairs,omitempty"`
}