qan

type Analyzer interface {
	Start() error
	Stop() error
	Status() map[string]string
	String() string
	Config() Config
	SetConfig(Config)
}

type AnalyzerFactory interface {
	Make(config Config, name string, mysqlConn mysql.Connector, restartChan <-chan bool, tickChan chan time.Time) Analyzer
}

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

type ByQueryTime []*event.QueryClass

type Config struct {
	proto.ServiceInstance
	// Manager
	CollectFrom       string // "slowlog" or "perfschema"
	Start             []mysql.Query
	Stop              []mysql.Query
	MaxWorkers        int
	Interval          uint  // minutes, "How often to report"
	MaxSlowLogSize    int64 // bytes, 0 = no max
	RemoveOldSlowLogs bool  // after rotating for MaxSlowLogSize
	// Worker
	ExampleQueries bool // only fingerprints if false
	WorkerRunTime  uint // seconds
	// Report
	ReportLimit uint
}

type Interval struct {
	Number    int
	StartTime time.Time // UTC
	StopTime  time.Time // UTC
	// slowlog
	Filename    string // slow_query_log_file
	StartOffset int64  // bytes @ StartTime
	EndOffset   int64  // bytes @ StopTime
}

type IntervalIter interface {
	Start()
	Stop()
	IntervalChan() chan *Interval
	TickChan() chan time.Time
}

type IntervalIterFactory interface {
	Make(analyzerType string, mysqlConn mysql.Connector, tickChan chan time.Time) IntervalIter
}

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

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

type Report struct {
	proto.ServiceInstance                     // MySQL instance
	StartTs               time.Time           // of interval, UTC
	EndTs                 time.Time           // of interval, UTC
	RunTime               float64             // seconds parsing data
	Global                *event.GlobalClass  // metrics for all data
	Class                 []*event.QueryClass // per-class metrics
	// slow log:
	SlowLogFile     string `json:",omitempty"` // not slow_query_log_file if rotated
	SlowLogFileSize int64  `json:",omitempty"`
	StartOffset     int64  `json:",omitempty"` // parsing starts
	EndOffset       int64  `json:",omitempty"` // parsing stops, but...
	StopOffset      int64  `json:",omitempty"` // ...parsing didn't complete if stop < end
}

type Result struct {
	Global     *event.GlobalClass  // metrics for all data
	Class      []*event.QueryClass // per-class metrics
	RunTime    float64             // seconds parsing data, hopefully < interval
	StopOffset int64               // slow log offset where parsing stopped, should be <= end offset
	Error      string              `json:",omitempty"`
}

type Worker interface {
	Setup(*Interval) error
	Run() (*Result, error)
	Stop() error
	Cleanup() error
	Status() map[string]string
}