122 lines
3.5 KiB
Go
122 lines
3.5 KiB
Go
package influxql
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
|
|
"github.com/influxdata/influxdb/models"
|
|
)
|
|
|
|
const (
|
|
// WarningLevel is the message level for a warning.
|
|
WarningLevel = "warning"
|
|
)
|
|
|
|
// TagSet is a fundamental concept within the query system. It represents a composite series,
|
|
// composed of multiple individual series that share a set of tag attributes.
|
|
type TagSet struct {
|
|
Tags map[string]string
|
|
Filters []Expr
|
|
SeriesKeys []string
|
|
Key []byte
|
|
}
|
|
|
|
// AddFilter adds a series-level filter to the Tagset.
|
|
func (t *TagSet) AddFilter(key string, filter Expr) {
|
|
t.SeriesKeys = append(t.SeriesKeys, key)
|
|
t.Filters = append(t.Filters, filter)
|
|
}
|
|
|
|
func (t *TagSet) Len() int { return len(t.SeriesKeys) }
|
|
func (t *TagSet) Less(i, j int) bool { return t.SeriesKeys[i] < t.SeriesKeys[j] }
|
|
func (t *TagSet) Swap(i, j int) {
|
|
t.SeriesKeys[i], t.SeriesKeys[j] = t.SeriesKeys[j], t.SeriesKeys[i]
|
|
t.Filters[i], t.Filters[j] = t.Filters[j], t.Filters[i]
|
|
}
|
|
|
|
// Reverse reverses the order of series keys and filters in the TagSet.
|
|
func (t *TagSet) Reverse() {
|
|
for i, j := 0, len(t.Filters)-1; i < j; i, j = i+1, j-1 {
|
|
t.Filters[i], t.Filters[j] = t.Filters[j], t.Filters[i]
|
|
t.SeriesKeys[i], t.SeriesKeys[j] = t.SeriesKeys[j], t.SeriesKeys[i]
|
|
}
|
|
}
|
|
|
|
// Message represents a user-facing message to be included with the result.
|
|
type Message struct {
|
|
Level string `json:"level"`
|
|
Text string `json:"text"`
|
|
}
|
|
|
|
// ReadOnlyWarning generates a warning message that tells the user the command
|
|
// they are using is being used for writing in a read only context.
|
|
//
|
|
// This is a temporary method while to be used while transitioning to read only
|
|
// operations for issue #6290.
|
|
func ReadOnlyWarning(stmt string) *Message {
|
|
return &Message{
|
|
Level: WarningLevel,
|
|
Text: fmt.Sprintf("deprecated use of '%s' in a read only context, please use a POST request instead", stmt),
|
|
}
|
|
}
|
|
|
|
// Result represents a resultset returned from a single statement.
|
|
// Rows represents a list of rows that can be sorted consistently by name/tag.
|
|
type Result struct {
|
|
// StatementID is just the statement's position in the query. It's used
|
|
// to combine statement results if they're being buffered in memory.
|
|
StatementID int
|
|
Series models.Rows
|
|
Messages []*Message
|
|
Partial bool
|
|
Err error
|
|
}
|
|
|
|
// MarshalJSON encodes the result into JSON.
|
|
func (r *Result) MarshalJSON() ([]byte, error) {
|
|
// Define a struct that outputs "error" as a string.
|
|
var o struct {
|
|
StatementID int `json:"statement_id"`
|
|
Series []*models.Row `json:"series,omitempty"`
|
|
Messages []*Message `json:"messages,omitempty"`
|
|
Partial bool `json:"partial,omitempty"`
|
|
Err string `json:"error,omitempty"`
|
|
}
|
|
|
|
// Copy fields to output struct.
|
|
o.StatementID = r.StatementID
|
|
o.Series = r.Series
|
|
o.Messages = r.Messages
|
|
o.Partial = r.Partial
|
|
if r.Err != nil {
|
|
o.Err = r.Err.Error()
|
|
}
|
|
|
|
return json.Marshal(&o)
|
|
}
|
|
|
|
// UnmarshalJSON decodes the data into the Result struct
|
|
func (r *Result) UnmarshalJSON(b []byte) error {
|
|
var o struct {
|
|
StatementID int `json:"statement_id"`
|
|
Series []*models.Row `json:"series,omitempty"`
|
|
Messages []*Message `json:"messages,omitempty"`
|
|
Partial bool `json:"partial,omitempty"`
|
|
Err string `json:"error,omitempty"`
|
|
}
|
|
|
|
err := json.Unmarshal(b, &o)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
r.StatementID = o.StatementID
|
|
r.Series = o.Series
|
|
r.Messages = o.Messages
|
|
r.Partial = o.Partial
|
|
if o.Err != "" {
|
|
r.Err = errors.New(o.Err)
|
|
}
|
|
return nil
|
|
}
|