mysql

Documentation

Index

• func Connect(config configuration.Config) (*sqlx.DB, error)
• func Disconnect()
• func KillMySQLProcess(killCommand string, dbConn *sqlx.DB) error
• type MysqlProcess
  • func GetLongRunningQueries(dbConn *sqlx.DB, config configuration.Config) ([]MysqlProcess, error)
• type SSHDialer
  • func (self *SSHDialer) Dial(addr string) (net.Conn, error)

Functions

func Connect

func Connect(config configuration.Config) (*sqlx.DB, error)

func Disconnect

func Disconnect()

func KillMySQLProcess

func KillMySQLProcess(killCommand string, dbConn *sqlx.DB) error

Types

type MysqlProcess

type MysqlProcess struct {
	ID             int            `db:"ID"`
	KillCommand    string         `db:"KILL_COMMAND"`
	DB             string         `db:"DB"`
	State          sql.NullString `db:"STATE"`
	Command        string         `db:"COMMAND"`
	Time           int            `db:"TIME"`
	Info           sql.NullString `db:"INFO"`
	TruncatedQuery string
}

func GetLongRunningQueries

func GetLongRunningQueries(dbConn *sqlx.DB, config configuration.Config) ([]MysqlProcess, error)

type SSHDialer

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

func (*SSHDialer) Dial

func (self *SSHDialer) Dial(addr string) (net.Conn, error)