mysql

Documentation

Index

• Constants
• func New(ctx context.Context, protoInstance proto.Instance) analyzer.Analyzer
• type MySQLAnalyzer
  • func (m *MySQLAnalyzer) Config() pc.QAN
  • func (m *MySQLAnalyzer) GetDefaults(uuid string) map[string]interface{}
  • func (m *MySQLAnalyzer) SetConfig(setConfig pc.QAN)
  • func (m *MySQLAnalyzer) Start() error
  • func (m *MySQLAnalyzer) Status() map[string]string
  • func (m *MySQLAnalyzer) Stop() error
  • func (m *MySQLAnalyzer) String() string
• type RealAnalyzer
  • func NewRealAnalyzer(logger *pct.Logger, config pc.QAN, it iter.IntervalIter, ...) *RealAnalyzer
  • func (a *RealAnalyzer) Config() pc.QAN
  • func (m *RealAnalyzer) GetDefaults(uuid string) map[string]interface{}
  • func (a *RealAnalyzer) SetConfig(config pc.QAN)
  • func (a *RealAnalyzer) Start() error
  • func (a *RealAnalyzer) Status() map[string]string
  • func (a *RealAnalyzer) Stop() error
  • func (a *RealAnalyzer) String() string
  • func (a *RealAnalyzer) TakeOverPerconaServerRotation() error

Constants

const MIN_SLOWLOG_ROTATION_SIZE int64 = 4096

Functions

func New

func New(ctx context.Context, protoInstance proto.Instance) analyzer.Analyzer

Types

type MySQLAnalyzer

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

MySQLAnalyzer is a proxy Analyzer between QAN manager and MySQL implementations of Slowlog Analyzer and Perfschema Analyzer

func (*MySQLAnalyzer) Config

func (m *MySQLAnalyzer) Config() pc.QAN

Config returns analyzer running configuration

func (*MySQLAnalyzer) GetDefaults

func (m *MySQLAnalyzer) GetDefaults(uuid string) map[string]interface{}

func (*MySQLAnalyzer) SetConfig

func (m *MySQLAnalyzer) SetConfig(setConfig pc.QAN)

SetConfig sets the config

func (*MySQLAnalyzer) Start

func (m *MySQLAnalyzer) Start() error

Start starts analyzer but doesn't wait until it exits

func (*MySQLAnalyzer) Status

func (m *MySQLAnalyzer) Status() map[string]string

Status returns list of statuses

func (*MySQLAnalyzer) Stop

func (m *MySQLAnalyzer) Stop() error

Stop stops running analyzer, waits until it stops

func (*MySQLAnalyzer) String

func (m *MySQLAnalyzer) String() string

String returns human readable identification of Analyzer

type RealAnalyzer

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

func NewRealAnalyzer

func NewRealAnalyzer(
	logger *pct.Logger,
	config pc.QAN,
	it iter.IntervalIter,
	mysqlConn mysql.Connector,
	restartChan chan proto.Instance,
	worker worker.Worker,
	clock ticker.Manager,
	spool data.Spooler,
) *RealAnalyzer

func (*RealAnalyzer) Config

func (a *RealAnalyzer) Config() pc.QAN

func (*RealAnalyzer) GetDefaults

func (m *RealAnalyzer) GetDefaults(uuid string) map[string]interface{}

func (*RealAnalyzer) SetConfig

func (a *RealAnalyzer) SetConfig(config pc.QAN)

func (*RealAnalyzer) Start

func (a *RealAnalyzer) Start() error

func (*RealAnalyzer) Status

func (a *RealAnalyzer) Status() map[string]string

func (*RealAnalyzer) Stop

func (a *RealAnalyzer) Stop() error

func (*RealAnalyzer) String

func (a *RealAnalyzer) String() string

func (*RealAnalyzer) TakeOverPerconaServerRotation

func (a *RealAnalyzer) TakeOverPerconaServerRotation() error

Disable Percona Server slow log rotation and handle internally using the max_slowlog_size value. The slow log worker must rotate slow logs by itself to ensure full and proper parsing across rotations.