metrics

type AggregateBucket string

type AggregateFunction string

type AggregationInterval string

type ByMetricName []MetricName

type CounterMetricsResponse struct {
	StartTimestamp int64       `json:"start_ts"`
	EndTimestamp   int64       `json:"end_ts"`
	Results        []QueryData `json:"results"`
}

type Filter struct {
	Key      string
	Value    string
	Operator string
}

type FilterOp string

type GaugeMetricsResponse struct {
	StartTimestamp int64       `json:"start_ts"`
	EndTimestamp   int64       `json:"end_ts"`
	Results        []QueryData `json:"results"`
}

type GaugeRow struct {
	MetricName        string            `ch:"MetricName"`
	MetricDescription string            `ch:"MetricDescription"`
	MetricUnit        string            `ch:"MetricUnit"`
	Fingerprint       string            `ch:"Fingerprint"`
	Attributes        map[string]string `ch:"Attributes"`
	Values            []float64         `ch:"Values"`
	LastValues        []float64         `ch:"LastValues"`
	Times             []time.Time       `ch:"Times"`
}

type HistogramDistributionData struct {
	MetricName        string                  `json:"name"`
	MetricDescription string                  `json:"description"`
	MetricUnit        string                  `json:"unit"`
	MetricType        string                  `json:"type"`
	Fingerprint       string                  `json:"fingerprint"`
	Data              []PerBucketDistribution `json:"data"`
}

type HistogramDistributionResponse struct {
	StartTimestamp int64                       `json:"start_ts"`
	EndTimestamp   int64                       `json:"end_ts"`
	Results        []HistogramDistributionData `json:"results"`
}

type HistogramDistributionRow struct {
	ProjectID         string    `ch:"ProjectId"`
	MetricName        string    `ch:"MetricName"`
	MetricDescription string    `ch:"MetricDescription"`
	MetricUnit        string    `ch:"MetricUnit"`
	Fingerprint       string    `ch:"Fingerprint"`
	StartTimeUnix     time.Time `ch:"StartTimeUnix"`
	AggTimeUnix       time.Time `ch:"AggTimeUnix"`
	AggTemp           int32     `ch:"AggTemp"`
	Min               float64   `ch:"Min"`
	Max               float64   `ch:"Max"`
	Count             uint64    `ch:"Count"`
	Sum               float64   `ch:"Sum"`
	Bounds            []float64 `ch:"Bounds"`
	BoundsHash        uint64    `ch:"BoundsHash"`
	SamplesCount      uint64    `ch:"SamplesCount"`
	Delta             []uint64  `ch:"Delta"`
	Cumulative        []uint64  `ch:"Cumulative"`
}

type MetricName struct {
	Name           string   `json:"name"`
	Description    string   `json:"description"`
	Attributes     []string `json:"attributes"`
	Type           string   `json:"type"`
	LastIngestedAt int64    `json:"last_ingested_at"`
}

type MetricNameFilters struct {
	ProjectID  int64    `uri:"project_id" binding:"required,numeric,min=1"`
	StartsWith string   `form:"starts_with"`
	Search     string   `form:"search"`
	Limit      int      `form:"limit" binding:"numeric"`
	Attributes []string `form:"attributes"`
}

type MetricNameGetFn func(context.Context) ([]MetricName, error)

type MetricNameResponse struct {
	Metrics []MetricName `json:"metrics"`
}

type MetricNameRow struct {
	ProjectID      string    `ch:"ProjectId"`
	Name           string    `ch:"MetricName"`
	Description    string    `ch:"MetricDescription"`
	Attributes     []string  `ch:"Attributes"`
	LastIngestedAt time.Time `ch:"LastIngestedAt"`
}

type MetricRow struct {
	MetricName        string            `ch:"MetricName"`
	MetricDescription string            `ch:"MetricDescription"`
	MetricUnit        string            `ch:"MetricUnit"`
	Fingerprint       string            `ch:"Fingerprint"`
	Attributes        map[string]string `ch:"Attributes"`
	Values            []float64         `ch:"Values"`
	Times             []time.Time       `ch:"Times"`
}

type MetricSearchMetadataResponse struct {
	MetricName               string   `json:"name"`
	MetricType               string   `json:"type"`
	MetricDescription        string   `json:"description"`
	AttributeKeys            []string `json:"attribute_keys"`
	LastIngestedAt           int64    `json:"last_ingested_at"`
	SupportedAggregations    []string `json:"supported_aggregations"`
	SupportedFunctions       []string `json:"supported_functions"`
	DefaultGroupByAttributes []string `json:"default_group_by_attributes"`
	DefaultGroupByFunction   string   `json:"default_group_by_function"`
}

type MetricSearchMetadataRow struct {
	MetricName        string    `ch:"MetricName"`
	MetricDescription string    `ch:"MetricDescription"`
	AttributeKeys     []string  `ch:"AttributeKeys"`
	LastIngestedAt    time.Time `ch:"LastIngestedAt"`
}

type MetricsResponse struct {
	StartTimestamp int64 `json:"start_ts"`
	EndTimestamp   int64 `json:"end_ts"`

	Results []QueryData `json:"results"`
}

type MockQuerier struct{}

type PerBucketDistribution struct {
	BucketsHash  uint64         `json:"bucketsHash"`
	Buckets      []string       `json:"buckets"`
	Distribution [][]QueryPoint `json:"distribution"`
}

type Querier interface {
	GetMetricNames(context.Context, *MetricNameFilters) (*MetricNameResponse, error)
	GetMetrics(context.Context, *QueryContext) (interface{}, error)
	GetSearchMetadata(context.Context, *QueryContext) (interface{}, error)
}

type Query struct {
	TargetMetric string   `json:"mname"`
	TargetType   string   `json:"mtype"`
	TargetVisual string   `json:"mvisual"`
	Filters      []Filter `json:"filters"`
}

type QueryContext struct {
	ProjectID int64 `json:"project_id"`

	Queries    map[string]*Query `json:"queries,omitempty"`
	Expression string            `json:"expression,omitempty"`

	StartTimestamp time.Time `json:"start_time"`
	EndTimestamp   time.Time `json:"end_time"`
}

type QueryData struct {
	MetricName        string            `json:"name"`
	MetricDescription string            `json:"description"`
	MetricUnit        string            `json:"unit"`
	MetricType        string            `json:"type"`
	Attributes        map[string]string `json:"attributes"`
	Values            []QueryPoint      `json:"values,omitempty"`
}

type QueryPoint [2]float64 // time, value

type SumMetricsResponse struct {
	StartTimestamp int64       `json:"start_ts"`
	EndTimestamp   int64       `json:"end_ts"`
	Results        []QueryData `json:"results"`
}