qan

Documentation

Index

• Constants
• Variables
• func SaveData(wsConn ws.Connector, agentId uint, dbh *MySQLMetricWriter, stats *stats.Stats) error
• func SparklineData(qr *Reporter, endTs int64, intervalTs int64, queryClassId uint, ...) []qp.QueryLog
• type MetricWriter
• type MySQLMetricWriter
  • func NewMySQLMetricWriter(dbm db.Manager, ih instance.DbHandler, m *query.Mini, stats *stats.Stats) *MySQLMetricWriter
  • func (h *MySQLMetricWriter) Write(report qp.Report) error
• type Reporter
  • func NewReporter(dbm db.Manager, stats *stats.Stats) *Reporter
  • func (qr *Reporter) Profile(instanceId uint, begin, end time.Time, r qp.RankBy, offset int, search string) (qp.Profile, error)

Constants

const (
	MAX_DATA_MSG  = 100
	THROTTLE_CODE = 299
)

const (
	MAX_ABSTRACT    = 100  // query_classes.abstract
	MAX_FINGERPRINT = 5000 // query_classes.fingerprint
)

Variables

var ClassCols []string = []string{
	`query_class_id`,
	`instance_id`,
	`start_ts`,
	`end_ts`,
	`query_count`,
	`lrq_count`,
}

var GlobalCols []string = []string{
	`instance_id`,
	`start_ts`,
	`end_ts`,
	`run_time`,
	`total_query_count`,
	`unique_query_count`,
	`rate_type`,
	`rate_limit`,
	`log_file`,
	`log_file_size`,
	`start_offset`,
	`end_offset`,
	`stop_offset`,
}

Functions

func SaveData

func SaveData(wsConn ws.Connector, agentId uint, dbh *MySQLMetricWriter, stats *stats.Stats) error

func SparklineData

func SparklineData(qr *Reporter, endTs int64, intervalTs int64, queryClassId uint, instanceId uint, begin, end time.Time) []qp.QueryLog

get data for spark-lines at query profile

Types

type MetricWriter

type MetricWriter interface {
	Write(report qan.Report) error
}

type MySQLMetricWriter

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

func NewMySQLMetricWriter

func NewMySQLMetricWriter(
	dbm db.Manager,
	ih instance.DbHandler,
	m *query.Mini,
	stats *stats.Stats,
) *MySQLMetricWriter

func (*MySQLMetricWriter) Write

func (h *MySQLMetricWriter) Write(report qp.Report) error

type Reporter

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

func NewReporter

func NewReporter(dbm db.Manager, stats *stats.Stats) *Reporter

func (*Reporter) Profile

func (qr *Reporter) Profile(instanceId uint, begin, end time.Time, r qp.RankBy, offset int, search string) (qp.Profile, error)