Function NewPool

IceFireDB-SQLProxy/pkg/mysql/client/pool.go:83–134

NewPool initializes new connection pool and uses params: addr, user, password, dbName and options. minAlive specifies the minimum number of open connections that the pool will try to maintain. maxAlive specifies the maximum number of open connections (for internal reasons, may be greater by 1

(
	logFunc LogFunc,
	minAlive int,
	maxAlive int,
	maxIdle int,
	addr string,
	user string,
	password string,
	dbName string,
	options ...func(conn *Conn),
)

//	  (for internal reasons, may be greater by 1 inside newConnectionProducer).
//	maxIdle specifies the maximum number of idle connections (see DefaultIdleTimeout).
func NewPool(
	logFunc LogFunc,
	minAlive int,
	maxAlive int,
	maxIdle int,
	addr string,
	user string,
	password string,
	dbName string,
	options ...func(conn *Conn),
) (*Pool, error) {
	if minAlive > maxAlive {
		minAlive = maxAlive
	}
	if maxIdle > maxAlive {
		maxIdle = maxAlive
	}
	if maxIdle <= minAlive {
		maxIdle = minAlive
	}

	pool := &Pool{
		logFunc:  logFunc,
		minAlive: minAlive,
		maxAlive: maxAlive,
		maxIdle:  maxIdle,

		idleCloseTimeout: Timestamp(math.Ceil(DefaultIdleTimeout.Seconds())),
		idlePingTimeout:  Timestamp(math.Ceil(MaxIdleTimeoutWithoutPing.Seconds())),

		connect: func() (*Conn, error) {
			return Connect(addr, user, password, dbName, options...)
		},

		readyConnection: make(chan Connection),
	}

	pool.synchro.idleConnections = make([]Connection, 0, pool.maxIdle)

	go pool.newConnectionProducer()

	if pool.minAlive > 0 {
		pool.logFunc(`Pool: Setup %d new connections (minimal pool size)...`, pool.minAlive)
		if err := pool.startNewConnections(pool.minAlive); err != nil {
			return nil, err
		}
	}

	go pool.closeOldIdleConnections()

	return pool, nil
}

func (pool *Pool) GetStats(stats *ConnectionStats) {
	pool.synchro.Lock()