factory

Documentation

Index

• func AbsDataFile(dataDir, fileName string) string
• type RealAnalyzerFactory
  • func NewRealAnalyzerFactory(logChan chan *proto.LogEntry, iterFactory qan.IntervalIterFactory, ...) *RealAnalyzerFactory
  • func (f *RealAnalyzerFactory) Make(config qan.Config, name string, mysqlConn mysql.Connector, ...) qan.Analyzer
• type RealIntervalIterFactory
  • func NewRealIntervalIterFactory(logChan chan *proto.LogEntry) *RealIntervalIterFactory
  • func (f *RealIntervalIterFactory) Make(analyzerType string, mysqlConn mysql.Connector, tickChan chan time.Time) qan.IntervalIter

Functions

func AbsDataFile

func AbsDataFile(dataDir, fileName string) string

Types

type RealAnalyzerFactory

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

func NewRealAnalyzerFactory

func NewRealAnalyzerFactory(
	logChan chan *proto.LogEntry,
	iterFactory qan.IntervalIterFactory,
	slowlogWorkerFactory slowlog.WorkerFactory,
	perfschemaWorkerFactory perfschema.WorkerFactory,
	spool data.Spooler,
	clock ticker.Manager,
) *RealAnalyzerFactory

func (*RealAnalyzerFactory) Make

func (f *RealAnalyzerFactory) Make(
	config qan.Config,
	name string,
	mysqlConn mysql.Connector,
	restartChan <-chan bool,
	tickChan chan time.Time,
) qan.Analyzer

type RealIntervalIterFactory

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

func NewRealIntervalIterFactory

func NewRealIntervalIterFactory(logChan chan *proto.LogEntry) *RealIntervalIterFactory

func (*RealIntervalIterFactory) Make

func (f *RealIntervalIterFactory) Make(analyzerType string, mysqlConn mysql.Connector, tickChan chan time.Time) qan.IntervalIter