slowlog

Documentation

Index

• func GetutcOffset(mysqlConn mysql.Connector) (time.Duration, error)
• type FilenameFunc
• type Iter
  • func NewIter(logger *pct.Logger, filename FilenameFunc, tickChan chan time.Time) *Iter
  • func (i *Iter) IntervalChan() chan *qan.Interval
  • func (i *Iter) Start()
  • func (i *Iter) Stop()
  • func (i *Iter) TickChan() chan time.Time
• type Job
  • func (j *Job) String() string
• type RealWorkerFactory
  • func NewRealWorkerFactory(logChan chan *proto.LogEntry) *RealWorkerFactory
  • func (f *RealWorkerFactory) Make(name string, config qan.Config, mysqlConn mysql.Connector) *Worker
• type Worker
  • func NewWorker(logger *pct.Logger, config qan.Config, mysqlConn mysql.Connector) *Worker
  • func (w *Worker) Cleanup() error
  • func (w *Worker) MakeLogParser(file *os.File, opts log.Options) log.LogParser
  • func (w *Worker) Run() (*qan.Result, error)
  • func (w *Worker) SetLogParser(p log.LogParser)
  • func (w *Worker) Setup(interval *qan.Interval) error
  • func (w *Worker) Status() map[string]string
  • func (w *Worker) Stop() error
• type WorkerFactory

Functions

func GetutcOffset

func GetutcOffset(mysqlConn mysql.Connector) (time.Duration, error)

Types

type FilenameFunc

type FilenameFunc func() (string, error)

type Iter

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

func NewIter

func NewIter(logger *pct.Logger, filename FilenameFunc, tickChan chan time.Time) *Iter

func (*Iter) IntervalChan

func (i *Iter) IntervalChan() chan *qan.Interval

func (*Iter) Start

func (i *Iter) Start()

func (*Iter) Stop

func (i *Iter) Stop()

func (*Iter) TickChan

func (i *Iter) TickChan() chan time.Time

type Job

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

func (*Job) String

func (j *Job) String() string

type RealWorkerFactory

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

func NewRealWorkerFactory

func NewRealWorkerFactory(logChan chan *proto.LogEntry) *RealWorkerFactory

func (*RealWorkerFactory) Make

func (f *RealWorkerFactory) Make(name string, config qan.Config, mysqlConn mysql.Connector) *Worker

type Worker

type Worker struct {

	// --
	ZeroRunTime bool // testing
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(logger *pct.Logger, config qan.Config, mysqlConn mysql.Connector) *Worker

func (*Worker) Cleanup

func (w *Worker) Cleanup() error

func (*Worker) MakeLogParser

func (w *Worker) MakeLogParser(file *os.File, opts log.Options) log.LogParser

func (*Worker) Run

func (w *Worker) Run() (*qan.Result, error)

func (*Worker) SetLogParser

func (w *Worker) SetLogParser(p log.LogParser)

func (*Worker) Setup

func (w *Worker) Setup(interval *qan.Interval) error

func (*Worker) Status

func (w *Worker) Status() map[string]string

func (*Worker) Stop

func (w *Worker) Stop() error

type WorkerFactory

type WorkerFactory interface {
	Make(name string, config qan.Config, mysqlConn mysql.Connector) *Worker
}