Versions in this module Expand all Collapse all v1 v1.3.10 Feb 12, 2018 v1.3.9 Feb 9, 2018 v1.3.8 Feb 6, 2018 Changes in this version + const CmdLoadAdminVariablesToRuntime + const CmdLoadMySQLVariablesToRuntime + const CmdLoadQueryRulesToRuntime + const CmdLoadSchedulerToRuntime + const CmdLoadServerToRuntime + const CmdLoadUserToRuntime + const CmdProxyFlushLogs + const CmdProxyKill + const CmdProxyPause + const CmdProxyReadOnly + const CmdProxyReadWrite + const CmdProxyRestart + const CmdProxyResume + const CmdProxyShutdown + const CmdProxyStart + const CmdProxyStop + const CmdSaveAdminVariablesToDisk + const CmdSaveMySQLVariablesToDisk + const CmdSaveQueryRulesToDisk + const CmdSaveSchedulerToDisk + const CmdSaveServerToDisk + const CmdSaveUserToDisk + const StmtAddOneQr + const StmtAddOneRHG + const StmtAddOneScheduler + const StmtAddOneServers + const StmtAddOneUser + const StmtDeleteOneQr + const StmtDeleteOneRHG + const StmtDeleteOneScheduler + const StmtDeleteOneServers + const StmtDeleteOneUser + const StmtFindAllQr + const StmtFindAllScheduler + const StmtFindAllServer + const StmtFindAllUserInfo + const StmtFindLastInsertId + const StmtFindLastRuleId + const StmtGlobalVariables + const StmtMySQLStatus + const StmtQueryAllRHGs + const StmtUpdateOneQr + const StmtUpdateOneQrNoCache + const StmtUpdateOneRHG + const StmtUpdateOneScheduler + const StmtUpdateOneServer + const StmtUpdateOneUser + const StmtUpdateOneVariable + func LoadAdminVariablesToRuntime(db *sql.DB) error + func LoadMySQLVariablesToRuntime(db *sql.DB) error + func LoadQueryRulesToRuntime(db *sql.DB) error + func LoadSchedulerToRuntime(db *sql.DB) error + func LoadServerToRuntime(db *sql.DB) error + func LoadUserToRuntime(db *sql.DB) error + func ProxyFlushLogs(db *sql.DB) error + func ProxyKill(db *sql.DB) error + func ProxyPause(db *sql.DB) error + func ProxyReadOnly(db *sql.DB) error + func ProxyReadWrite(db *sql.DB) error + func ProxyRestart(db *sql.DB) error + func ProxyResume(db *sql.DB) error + func ProxyShutdown(db *sql.DB) error + func ProxyStart(db *sql.DB) error + func ProxyStop(db *sql.DB) error + func SaveAdminVariablesToDisk(db *sql.DB) error + func SaveMySQLVariablesToDisk(db *sql.DB) error + func SaveQueryRulesToDisk(db *sql.DB) error + func SaveSchedulerToDisk(db *sql.DB) error + func SaveServerToDisk(db *sql.DB) error + func SaveUserToDisk(db *sql.DB) error + func UpdateOneConfig(db *sql.DB, var_name string, var_value string) error + type Conn struct + Addr string + Charset string + Collation string + DBI string + Database string + Password string + Port uint64 + Retry uint64 + User string + func NewConn(addr string, port uint64, user string, password string) (*Conn, error) + func (ps *Conn) CloseConn(db *sql.DB) error + func (ps *Conn) MakeDBI() + func (ps *Conn) OpenConn() (*sql.DB, error) + func (ps *Conn) SetCharset(charset string) + func (ps *Conn) SetCollation(collation string) + func (ps *Conn) SetRetry(retry uint64) + type PsStatus struct + Active_Transactions int64 + Backend_query_time_nsec int64 + Client_Connections_aborted int64 + Client_Connections_connected int64 + Client_Connections_created int64 + Client_Connections_non_idle int64 + Com_autocommit int64 + Com_autocommit_filtered int64 + Com_commit int64 + Com_commit_filtered int64 + Com_rollback int64 + Com_rollback_filtered int64 + Com_stmt_close int64 + Com_stmt_execute int64 + Com_stmt_prepare int64 + ConnPool_get_conn_failure int64 + ConnPool_get_conn_immediate int64 + ConnPool_get_conn_success int64 + ConnPool_memory_bytes int64 + MySQL_Monitor_Workers int64 + MySQL_Thread_Workers int64 + Mysql_backend_buffers_bytes int64 + Mysql_frontend_buffers_bytes int64 + Mysql_session_internal_bytes int64 + ProxySQL_Uptime int64 + Queries_backends_bytes_recv int64 + Queries_backends_bytes_sent int64 + Query_Cache_Entries int64 + Query_Cache_Memory_bytes int64 + Query_Cache_Purged int64 + Query_Cache_bytes_IN int64 + Query_Cache_bytes_OUT int64 + Query_Cache_count_GET int64 + Query_Cache_count_GET_OK int64 + Query_Cache_count_SET int64 + Query_Processor_time_nsec int64 + Questions int64 + SQLite3_memory_bytes int64 + Server_Connections_aborted int64 + Server_Connections_connected int64 + Server_Connections_created int64 + Servers_table_version int64 + Slow_queries int64 + Stmt_Active_Total int64 + Stmt_Active_Unique int64 + Stmt_Max_Stmt_id int64 + func (ps *PsStatus) GetProxySqlStatus(db *sql.DB) PsStatus + type QueryRules struct + Active uint64 + Apply uint64 + Cache_ttl uint64 + Client_addr string + Comment string + Delay uint64 + Destination_hostgroup uint64 + Digest string + Error_msg string + FlagIN uint64 + FlagOUT uint64 + Log uint64 + Match_digest string + Match_pattern string + Mirror_flagOUT uint64 + Mirror_hostgroup uint64 + Negate_match_pattern uint64 + Proxy_addr string + Proxy_port uint64 + Reconnect uint64 + Replace_pattern string + Retries uint64 + Rule_id uint64 + Schemaname string + Timeout uint64 + Username string + func FindAllQr(db *sql.DB, limit uint64, skip uint64) ([]QueryRules, error) + func NewQr(username string, destination_hostgroup uint64) (*QueryRules, error) + func (qr *QueryRules) AddOneQr(db *sql.DB) error + func (qr *QueryRules) DeleteOneQr(db *sql.DB) error + func (qr *QueryRules) SetProxyPort(proxy_port uint64) + func (qr *QueryRules) SetQrActive(active uint64) + func (qr *QueryRules) SetQrApply(apply uint64) + func (qr *QueryRules) SetQrCacheTTL(cache_ttl uint64) + func (qr *QueryRules) SetQrClientAddr(client_addr string) + func (qr *QueryRules) SetQrDelay(delay uint64) + func (qr *QueryRules) SetQrDestHostGroup(destination_hostgroup uint64) + func (qr *QueryRules) SetQrDigest(digest string) + func (qr *QueryRules) SetQrErrorMsg(error_msg string) + func (qr *QueryRules) SetQrFlagIN(flag_in uint64) + func (qr *QueryRules) SetQrFlagOut(flag_out uint64) + func (qr *QueryRules) SetQrLog(log uint64) + func (qr *QueryRules) SetQrMatchDigest(match_digest string) + func (qr *QueryRules) SetQrMatchPattern(match_pattern string) + func (qr *QueryRules) SetQrMirrorFlagOUT(mirror_flagout uint64) + func (qr *QueryRules) SetQrMirrorHostgroup(mirror_hostgroup uint64) + func (qr *QueryRules) SetQrNegateMatchPattern(negate_match_pattern uint64) + func (qr *QueryRules) SetQrProxyAddr(proxy_addr string) + func (qr *QueryRules) SetQrReconnect(reconnect uint64) + func (qr *QueryRules) SetQrReplacePattern(replace_pattern string) + func (qr *QueryRules) SetQrRetries(retries uint64) + func (qr *QueryRules) SetQrRuleid(rule_id uint64) + func (qr *QueryRules) SetQrSchemaname(schema_name string) + func (qr *QueryRules) SetQrTimeOut(timeout uint64) + func (qr *QueryRules) UpdateOneQrInfo(db *sql.DB) error + type ReplicationHostgroup struct + Comment string + ReaderHostgroup uint64 + WriterHostgroup uint64 + func NewRHG(whg uint64, rhg uint64) (*ReplicationHostgroup, error) + func QueryAllRHG(db *sql.DB, limit uint64, skip uint64) ([]ReplicationHostgroup, error) + func (rhg *ReplicationHostgroup) AddOneRHG(db *sql.DB) error + func (rhg *ReplicationHostgroup) DeleteOneRHG(db *sql.DB) error + func (rhg *ReplicationHostgroup) SetComment(comment string) + func (rhg *ReplicationHostgroup) SetReaderHostGroup(reader uint64) + func (rhg *ReplicationHostgroup) SetWriterHostGroup(writer uint64) + func (rhg *ReplicationHostgroup) UpdateOneRHG(db *sql.DB) error + type Schedulers struct + Active int64 + Arg1 string + Arg2 string + Arg3 string + Arg4 string + Arg5 string + Comment string + FileName string + Id int64 + IntervalMs int64 + func FindAllSchedulerInfo(db *sql.DB, limit uint64, skip uint64) ([]Schedulers, error) + func NewSch(filename string, interval_ms int64) (*Schedulers, error) + func (sched *Schedulers) SetSchedulerActive(active int64) + func (sched *Schedulers) SetSchedulerArg1(arg1 string) + func (sched *Schedulers) SetSchedulerArg2(arg2 string) + func (sched *Schedulers) SetSchedulerArg3(arg3 string) + func (sched *Schedulers) SetSchedulerArg4(arg4 string) + func (sched *Schedulers) SetSchedulerArg5(arg5 string) + func (sched *Schedulers) SetSchedulerId(id int64) + func (sched *Schedulers) SetSchedulerIntervalMs(interval_ms int64) + func (schld *Schedulers) AddOneScheduler(db *sql.DB) error + func (schld *Schedulers) DeleteOneScheduler(db *sql.DB) error + func (schld *Schedulers) UpdateOneSchedulerInfo(db *sql.DB) error + type Servers struct + Comment string + Compression uint64 + HostGroupId uint64 + HostName string + MaxConnections uint64 + MaxLatencyMs uint64 + MaxReplicationLag uint64 + Port uint64 + Status string + UseSsl uint64 + Weight uint64 + func FindAllServerInfo(db *sql.DB, limit uint64, skip uint64) ([]Servers, error) + func NewServer(hostgroup_id uint64, hostname string, port uint64) (*Servers, error) + func (srvs *Servers) AddOneServers(db *sql.DB) error + func (srvs *Servers) DeleteOneServers(db *sql.DB) error + func (srvs *Servers) SetServerCompression(compression uint64) + func (srvs *Servers) SetServerMaxConnection(max_connections uint64) + func (srvs *Servers) SetServerMaxLatencyMs(max_latency_ms uint64) + func (srvs *Servers) SetServerMaxReplicationLag(max_replication_lag uint64) + func (srvs *Servers) SetServerStatus(status string) + func (srvs *Servers) SetServerUseSSL(use_ssl uint64) + func (srvs *Servers) SetServerWeight(weight uint64) + func (srvs *Servers) SetServersComment(comment string) + func (srvs *Servers) UpdateOneServerInfo(db *sql.DB) error + type Status struct + Value int64 + VariablesName string + type Users struct + Active uint64 + Backend uint64 + DefaultHostgroup uint64 + DefaultSchema string + FastForward uint64 + Frontend uint64 + MaxConnections uint64 + Password string + SchemaLocked uint64 + TransactionPersistent uint64 + UseSsl uint64 + Username string + func FindAllUserInfo(db *sql.DB, limit uint64, skip uint64) ([]Users, error) + func NewUser(username string, password string, default_hostgroup uint64, ...) (*Users, error) + func (users *Users) AddOneUser(db *sql.DB) error + func (users *Users) DeleteOneUser(db *sql.DB) error + func (users *Users) SetBackend(backend uint64) + func (users *Users) SetFastForward(fast_forward uint64) + func (users *Users) SetFrontend(frontend uint64) + func (users *Users) SetMaxConnections(max_connections uint64) + func (users *Users) SetSchemaLocked(schema_locked uint64) + func (users *Users) SetTransactionPersistent(transaction_persistent uint64) + func (users *Users) SetUseSSL(use_ssl uint64) + func (users *Users) SetUserActive(active uint64) + func (users *Users) UpdateOneUserInfo(db *sql.DB) error + type Variables struct + Value string + VariablesName string + func GetConfig(db *sql.DB) ([]Variables, error)