qan

type ByQueryTime []*mysqlLog.QueryClass

type Config struct {
	proto.ServiceInstance
	// Manager
	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 FileIntervalIter struct {
	// contains filtered or unexported fields
}

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

type FilenameFunc func() (string, error)

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

type IntervalIter interface {
	Start()
	Stop()
	IntervalChan() chan *Interval
}

type IntervalIterFactory interface {
	Make(filename FilenameFunc, tickChan chan time.Time) IntervalIter
}

type Job struct {
	Id             string
	SlowLogFile    string
	RunTime        time.Duration
	StartOffset    int64
	EndOffset      int64
	ExampleQueries bool
	// --
	ZeroRunTime bool // testing
}

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

type Report struct {
	proto.ServiceInstance
	StartTs     time.Time // UTC
	EndTs       time.Time // UTC
	SlowLogFile string    // not slow_query_log_file if rotated
	StartOffset int64     // parsing starts
	EndOffset   int64     // parsing stops, but...
	StopOffset  int64     // ...parsing didn't complete if stop < end
	RunTime     float64   // seconds
	Global      *mysqlLog.GlobalClass
	Class       []*mysqlLog.QueryClass
}

type Result struct {
	StopOffset int64
	RunTime    float64
	Error      string `json:",omitempty"`
	Global     *mysqlLog.GlobalClass
	Classes    []*mysqlLog.QueryClass
}

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

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

type Worker interface {
	Name() string
	Status() string
	Run(job *Job) (*Result, error)
}

type WorkerFactory interface {
	Make(name string) Worker
}