proxysqlutil

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

type IAdmin interface {
	// Connections returns the connection map of all clients
	Connections() mysqlutil.IAdminConnections

	// Close the admin connections
	Close()

	// SyncMysqlUsers sync users to proxysql
	SyncMysqlUsers(ctx context.Context, addr string, defaultHostGroup, maxConnections int, expectedUsers, foundUsers mysqlutil.Users) error

	// SyncMysqlReplicationHostGroup sync server to proxysql
	SyncMysqlReplicationHostGroup(ctx context.Context, addr string, hostgroup *ReplicationHostgroup) error

	// SyncMysqlReplicationServers sync hostGroup to proxysql
	SyncMysqlReplicationServers(ctx context.Context, addr string, expectedServers, foundServers Servers) error

	// GetRuntimeMysqlUsers get runtime user from proxysql
	GetRuntimeMysqlUsers(ctx context.Context, addr string) (mysqlutil.Users, error)

	// GetRuntimeMysqlReplicationHostGroup get runtime hostGroup from proxysql
	GetRuntimeMysqlReplicationHostGroup(ctx context.Context, addr string, writerHostGroup int) (*ReplicationHostgroup, error)

	// GetRuntimeMysqlReplicationServers get runtime server from proxysql
	GetRuntimeMysqlReplicationServers(ctx context.Context, addr string) (Servers, error)

	// SyncMysqlVersion sync the mysql-server_version variable
	SyncMysqlVersion(ctx context.Context, addr, version string) error
}

type ReplicationHostgroup struct {
	WriterHostGroupId int
	ReaderHostGroupId int
	CheckType         string
	Comment           string
}

type Server struct {
	HostGroupId    int
	Hostname       string
	Port           int
	MaxConnections int
}

type Servers map[string]*Server