opentsdb

type Filter struct {
	Examples    string     `json:"examples"`
	Description string     `json:"description"`
	Translator  Translator `json:"-"`
}

type FilterSpec struct {
	Type       string `json:"type"`
	TagKey     string `json:"tagk"`
	Expression string `json:"filter"`
	GroupBy    bool   `json:"groupBy"`
}

type IndexResponse struct {
	Index int `json:"index"`
}

type OpenTSDB struct {
	ReqCounter  prometheus.Counter
	ErrCounter  prometheus.Counter
	WarnCounter prometheus.Counter
}

type Query struct {
	// The name of an aggregation function to use
	Aggregator string `json:"aggregator"`
	// The name of a metric stored in the system
	Metric string `json:"metric"`
	// Whether or not the data should be converted into deltas before returning
	Rate *bool `json:"rate"`
	// Monotonically increasing counter handling options
	RateOptions *RateOptions `json:"rateOptions"`
	// An optional downsampling function to reduce the amount of data returned
	Downsample *string `json:"downsample"`
	// To drill down to specific timeseries or group results by tag
	Tags map[string]string `json:"tags"`
	// Filters the timeseries emitted in the results
	Filters []FilterSpec `json:"filters"`
	// Returns the series that include only the tag keys provided in the filters.
	ExplicitTags bool `json:"explicitTags"`
}

type QueryRequest struct {
	// The start time for the query
	Start *TSDBTime `json:"start"`
	// An end time for the query. Default value = time.Now()
	End         *TSDBTime `json:"end"`
	NoTimeRange bool      `json:"-"`
	// One or more sub queries used to select the time series to return
	Queries []*Query `json:"queries"`
	// Whether or not to output data point timestamps in milliseconds or seconds
	MSResolution *bool `json:"msResolution"`
	Delete       bool  `json:"delete"`
}

type QueryResponse struct {
	Metric        string             `json:"metric"`
	Tags          map[string]string  `json:"tags"`
	Query         IndexResponse      `json:"query"`
	AggregateTags []string           `json:"aggregateTags"`
	DPs           map[string]float64 `json:"dps"`
}

type RateOptions struct {
	// Whether or not the underlying data is a monotonically increasing counter that may roll over
	Counter bool `json:"counter"`
	// A positive integer representing the maximum value for the counter
	CounterMax *int64 `json:"counterMax"`
	// An optional value that, when exceeded, will cause the aggregator to return
	// a 0 instead of the calculated rate
	ResetValue *int64 `json:"resetValue"`
	// Optional: Whether or not to simply drop rolled-over or reset data points.
	DropResets bool `json:"dropResets"`
}

type Response struct {
	PointsCount int             `json:"pointsCount"`
	Buffer      json.RawMessage `json:"series"`
}

type SuggestQuery struct {
	Type string `schema:"type" json:"type"` // "metric", "tagk" or "tagv"
	Q    string `schema:"q"    json:"q,omitempty"`
	Max  int    `schema:"max"  json:"max,omitempty"`
}

type TSDBTime struct {
	time.Time
}

type Translator func(string) string

type Validatable interface {
	Validate() error
}