mysql

Documentation

Index

• func AlertBasicInfo(mysql *xorm.Engine, db_id int)
• func AlertConnect(mysql *xorm.Engine, db_id int)
• func CheckExpression(tri common.Trigger, item_value string) int
• func Check_Item_Status(mysql *xorm.Engine, db_id int, trigger_type string, item_name string, ...)
• func ExecTriggers(mysql *xorm.Engine, db_id int, trigger_type string, item_name string, ...)
• func GatherBasicInfo(db *sql.DB, mysql *xorm.Engine, db_id int, host string, port int, alias string) error
• func GatherDbStatus(mysql *xorm.Engine, db_id int)
• func GatherMetricValue(db *sql.DB, mysql *xorm.Engine, db_id int, host string, port int, alias string)
• func GenerateMaster(mysql *xorm.Engine, dr_id int, db_id int, connStr string)
• func GenerateMySQLDrStats(wg *sync.WaitGroup, mysql *xorm.Engine, dis common.Dr)
• func GenerateMySQLStats(wg *sync.WaitGroup, mysql *xorm.Engine, db_id int, host string, port int, ...)
• func GenerateSlave(mysql *xorm.Engine, dr_id int, db_id int, connStr string)
• func GetColumnValue(mysql *xorm.Engine, column string, db_id int) string
• func GetConnect(mysql *xorm.Engine, db_id int) string
• func GetDsn(db *xorm.Engine, db_id int, asset_type int) (string, error)
• func GetGlobalStatus(db *sql.DB) (map[string]string, error)
• func GetGlobalVariable(db *sql.DB, variable string) (string, error)
• func GetGlobalVariables(db *sql.DB) (map[string]string, error)
• func GetLogPerSecond(mysql *xorm.Engine, db_id int) int
• func GetMasterLogSpace(db *sql.DB) (int, error)
• func GetMasterStatus(db *sql.DB) (string, string, error)
• func GetProcessWaits(db *sql.DB) int
• func GetQPS(mysql *xorm.Engine, db_id int) int
• func GetReplicationDelay(mysql *xorm.Engine, db_id int) string
• func GetReplicationStatus(mysql *xorm.Engine, db_id int) string
• func GetRole(db *sql.DB) string
• func GetTPS(mysql *xorm.Engine, db_id int) int
• func GetVersion(db *sql.DB) string
• func MoveToHistory(mysql *xorm.Engine, table_name string, key_name string, key_value int)
• func StorageMetricData(mysql *xorm.Engine, db_id int, metric string, timestamp string, value string, ...)
• func Update_Item_Tips(mysql *xorm.Engine, db_id int, field string, value string, trigger_type string, ...)

Functions

func AlertBasicInfo

func AlertBasicInfo(mysql *xorm.Engine, db_id int)

func AlertConnect

func AlertConnect(mysql *xorm.Engine, db_id int)

func CheckExpression

func CheckExpression(tri common.Trigger, item_value string) int

func Check_Item_Status

func Check_Item_Status(mysql *xorm.Engine, db_id int, trigger_type string, item_name string, item_value string)

func ExecTriggers

func ExecTriggers(mysql *xorm.Engine, db_id int, trigger_type string, item_name string, item_value string)

func GatherBasicInfo

func GatherBasicInfo(db *sql.DB, mysql *xorm.Engine, db_id int, host string, port int, alias string) error

func GatherDbStatus

func GatherDbStatus(mysql *xorm.Engine, db_id int)

func GatherMetricValue

func GatherMetricValue(db *sql.DB, mysql *xorm.Engine, db_id int, host string, port int, alias string)

func GenerateMaster

func GenerateMaster(mysql *xorm.Engine, dr_id int, db_id int, connStr string)

func GenerateMySQLDrStats

func GenerateMySQLDrStats(wg *sync.WaitGroup, mysql *xorm.Engine, dis common.Dr)

func GenerateMySQLStats

func GenerateMySQLStats(wg *sync.WaitGroup, mysql *xorm.Engine, db_id int, host string, port int, alias string, is_alert int)

func GenerateSlave

func GenerateSlave(mysql *xorm.Engine, dr_id int, db_id int, connStr string)

func GetColumnValue

func GetColumnValue(mysql *xorm.Engine, column string, db_id int) string

func GetConnect

func GetConnect(mysql *xorm.Engine, db_id int) string

func GetDsn

func GetDsn(db *xorm.Engine, db_id int, asset_type int) (string, error)

func GetGlobalStatus

func GetGlobalStatus(db *sql.DB) (map[string]string, error)

func GetGlobalVariable

func GetGlobalVariable(db *sql.DB, variable string) (string, error)

func GetGlobalVariables

func GetGlobalVariables(db *sql.DB) (map[string]string, error)

func GetLogPerSecond

func GetLogPerSecond(mysql *xorm.Engine, db_id int) int

func GetMasterLogSpace

func GetMasterLogSpace(db *sql.DB) (int, error)

func GetMasterStatus

func GetMasterStatus(db *sql.DB) (string, string, error)

func GetProcessWaits

func GetProcessWaits(db *sql.DB) int

func GetQPS

func GetQPS(mysql *xorm.Engine, db_id int) int

func GetReplicationDelay

func GetReplicationDelay(mysql *xorm.Engine, db_id int) string

func GetReplicationStatus

func GetReplicationStatus(mysql *xorm.Engine, db_id int) string

func GetRole

func GetRole(db *sql.DB) string

func GetTPS

func GetTPS(mysql *xorm.Engine, db_id int) int

func GetVersion

func GetVersion(db *sql.DB) string

func MoveToHistory

func MoveToHistory(mysql *xorm.Engine, table_name string, key_name string, key_value int)

func StorageMetricData

func StorageMetricData(mysql *xorm.Engine, db_id int, metric string, timestamp string, value string, counterType string)

Storage metric data

func Update_Item_Tips

func Update_Item_Tips(mysql *xorm.Engine, db_id int, field string, value string, trigger_type string, level int, severity string)