proxysql

package

v1.1.0 Latest Latest Go to latest Published: Aug 20, 2020 License: MIT Imports: 9 Imported by: 0

Details

This package implements freno store support for ProxySQL

Freno will probe servers found in the stats.stats_mysql_connection_pool ProxySQL admin table that have either status:

ONLINE - connect, ping and replication checks pass
SHUNNED_REPLICATION_LAG - connect and ping checks pass, but replication is lagging

All other statuses are considered unhealthy and therefore are ignored by freno, eg:

The ProxySQL --no-monitor flag is not set
The ProxySQL monitor module is enabled, eg: mysql-monitor_enabled is true
The max_replication_lag column is defined for backend servers in the mysql_servers admin table
- This ensures servers with lag do not receive reads but are still probed by freno

This section is empty.

This section is empty.

This section is empty.

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

Client is the ProxySQL admin client

func NewClient(defaultIgnoreServerTTL time.Duration) *Client

NewClient returns a new ProxySQL admin client

func (c *Client) CloseDB(addr string)

CloseDB closes a ProxySQL admin connection based on an address string

func (c *Client) GetDB(settings config.ProxySQLConfigurationSettings) (*sql.DB, string, error)

GetDB returns a configured ProxySQL admin connection

func (c *Client) GetServers(db *sql.DB, settings config.ProxySQLConfigurationSettings) (servers []*MySQLConnectionPoolServer, err error)

GetServers returns a list of MySQLConnectionPoolServers with 'ONLINE' or 'SHUNNED_REPLICATION_LAG' status, based on hostgroup ID

type MySQLConnectionPoolServer struct {
	Host   string
	Port   int32
	Status string
}

MySQLConnectionPoolServer represents a row in the stats_mysql_connection_pool table

func (ms *MySQLConnectionPoolServer) Address() string

Address returns a string of the hostname/port of a server