query

type Aggregation struct {
	Function string
	Query    Query
	By       []string // group by labels
}

type BinaryOp struct {
	Left     Query
	Operator BinaryOperator
	Right    Query
}

type BinaryOperator string

type ExecutionContext struct {
	StartTime *time.Time
	EndTime   *time.Time
	Limit     int
	AgentID   *uuid.UUID
	GroupID   *string
}

type Executor struct {
	// contains filtered or unexported fields
}

type ExecutorVisitor struct {
	// contains filtered or unexported fields
}

type Function struct {
	Name        string
	Description string
	Apply       func([]QueryResult) (interface{}, error)
}

type FunctionCall struct {
	Name string
	Args []Query
}

type Parser struct {
	// contains filtered or unexported fields
}

type Query interface {
	Accept(visitor QueryVisitor) (interface{}, error)
}

type QueryMeta struct {
	ExecutionTime time.Duration `json:"execution_time"`
	RowCount      int           `json:"row_count"`
	QueryType     string        `json:"query_type"`
	UsedRollups   bool          `json:"used_rollups"`
}

type QueryResult struct {
	Type      TelemetryType          `json:"type"`
	Timestamp time.Time              `json:"timestamp"`
	Labels    map[string]string      `json:"labels"`
	Value     interface{}            `json:"value"`
	Data      map[string]interface{} `json:"data,omitempty"`
}

type QueryVisitor interface {
	VisitTelemetryQuery(*TelemetryQuery) (interface{}, error)
	VisitBinaryOp(*BinaryOp) (interface{}, error)
	VisitFunctionCall(*FunctionCall) (interface{}, error)
	VisitAggregation(*Aggregation) (interface{}, error)
}

type Selector struct {
	Label    string
	Operator SelectorOperator
	Value    string
}

type SelectorOperator string

type TelemetryQuery struct {
	Type      TelemetryType
	Selectors map[string]*Selector
	Duration  time.Duration
	StartTime *time.Time
	EndTime   *time.Time
	Limit     int
}

type TelemetryType string

type Token struct {
	Type  TokenType
	Value string
	Pos   int
}

type TokenType int