query

Documentation

Index

• Constants
• type DefaultQuery
  • func NewDefaultQuery(vmselectHandler http.HandlerFunc, docDB docdb.DocDB) *DefaultQuery
  • func (dq *DefaultQuery) Close()
  • func (dq *DefaultQuery) Instances(startSecs, endSecs int, fill *[]InstanceItem) error
  • func (dq *DefaultQuery) Records(name string, startSecs, endSecs, windowSecs, top int, ...) error
  • func (dq *DefaultQuery) Summary(startSecs, endSecs, windowSecs, top int, instance, instanceType string, ...) error
  • func (dq *DefaultQuery) SummaryBy(startSecs, endSecs, windowSecs, top int, instance, instanceType, aggBy string, ...) error
• type InstanceItem
• type Query
• type RecordItem
• type RecordKey
• type RecordPlanItem
• type SummaryByItem
• type SummaryItem
• type SummaryPlanItem
• type TopKSlice
  • func (s TopKSlice) Len() int
  • func (s TopKSlice) Less(i, j int) bool
  • func (s TopKSlice) Swap(i, j int)

Constants

const (
	// AggLevelQuery is the query level aggregation
	AggLevelQuery = "query"
	// AggLevelTable is the table level aggregation
	AggLevelTable = "table"
	// AggLevelDB is the db level aggregation
	AggLevelDB = "db"
)

Types

type DefaultQuery

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

func NewDefaultQuery

func NewDefaultQuery(vmselectHandler http.HandlerFunc, docDB docdb.DocDB) *DefaultQuery

func (*DefaultQuery) Close

func (dq *DefaultQuery) Close()

func (*DefaultQuery) Instances

func (dq *DefaultQuery) Instances(startSecs, endSecs int, fill *[]InstanceItem) error

func (*DefaultQuery) Records

func (dq *DefaultQuery) Records(name string, startSecs, endSecs, windowSecs, top int, instance, instanceType string, fill *[]RecordItem) error

func (*DefaultQuery) Summary

func (dq *DefaultQuery) Summary(startSecs, endSecs, windowSecs, top int, instance, instanceType string, fill *[]SummaryItem) error

func (*DefaultQuery) SummaryBy

func (dq *DefaultQuery) SummaryBy(startSecs, endSecs, windowSecs, top int, instance, instanceType, aggBy string, fill *[]SummaryByItem) error

type InstanceItem

type InstanceItem struct {
	Instance     string `json:"instance"`
	InstanceType string `json:"instance_type"`
}

type Query

type Query interface {
	Records(name string, startSecs, endSecs, windowSecs, top int, instance, instanceType string, fill *[]RecordItem) error
	Summary(startSecs, endSecs, windowSecs, top int, instance, instanceType string, fill *[]SummaryItem) error
	SummaryBy(startSecs, endSecs, windowSecs, top int, instance, instanceType, by string, fill *[]SummaryByItem) error
	Instances(startSecs, endSecs int, fill *[]InstanceItem) error
	Close()
}

type RecordItem

type RecordItem struct {
	SQLDigest string           `json:"sql_digest"`
	SQLText   string           `json:"sql_text"`
	IsOther   bool             `json:"is_other"`
	Plans     []RecordPlanItem `json:"plans"`
}

type RecordKey

type RecordKey struct {
	SQLDigest  string
	PlanDigest string
}

type RecordPlanItem

type RecordPlanItem struct {
	PlanDigest       string   `json:"plan_digest"`
	PlanText         string   `json:"plan_text"`
	TimestampSec     []uint64 `json:"timestamp_sec"`
	CPUTimeMs        []uint64 `json:"cpu_time_ms,omitempty"`
	ReadRows         []uint64 `json:"read_rows,omitempty"`
	ReadIndexes      []uint64 `json:"read_indexes,omitempty"`
	WriteRows        []uint64 `json:"write_rows,omitempty"`
	WriteIndexes     []uint64 `json:"write_indexes,omitempty"`
	SQLExecCount     []uint64 `json:"sql_exec_count,omitempty"`
	SQLDurationSum   []uint64 `json:"sql_duration_sum,omitempty"`
	SQLDurationCount []uint64 `json:"sql_duration_count,omitempty"`
}

type SummaryByItem

type SummaryByItem struct {
	Text         string   `json:"text"`
	TimestampSec []uint64 `json:"timestamp_sec"`
	CPUTimeMs    []uint64 `json:"cpu_time_ms,omitempty"`
	CPUTimeMsSum uint64   `json:"cpu_time_ms_sum"`
	IsOther      bool     `json:"is_other"`
}

type SummaryItem

type SummaryItem struct {
	SQLDigest         string            `json:"sql_digest"`
	SQLText           string            `json:"sql_text"`
	IsOther           bool              `json:"is_other"`
	CPUTimeMs         uint64            `json:"cpu_time_ms"`
	ExecCountPerSec   float64           `json:"exec_count_per_sec"`
	DurationPerExecMs float64           `json:"duration_per_exec_ms"`
	ScanRecordsPerSec float64           `json:"scan_records_per_sec"`
	ScanIndexesPerSec float64           `json:"scan_indexes_per_sec"`
	Plans             []SummaryPlanItem `json:"plans"`
}

type SummaryPlanItem

type SummaryPlanItem struct {
	PlanDigest        string   `json:"plan_digest"`
	PlanText          string   `json:"plan_text"`
	TimestampSec      []uint64 `json:"timestamp_sec"`
	CPUTimeMs         []uint64 `json:"cpu_time_ms,omitempty"`
	ExecCountPerSec   float64  `json:"exec_count_per_sec"`
	DurationPerExecMs float64  `json:"duration_per_exec_ms"`
	ScanRecordsPerSec float64  `json:"scan_records_per_sec"`
	ScanIndexesPerSec float64  `json:"scan_indexes_per_sec"`
}

type TopKSlice

type TopKSlice []sqlGroup

func (TopKSlice) Len

func (s TopKSlice) Len() int

func (TopKSlice) Less

func (s TopKSlice) Less(i, j int) bool

func (TopKSlice) Swap

func (s TopKSlice) Swap(i, j int)