Method RetireConns

internal/pool/pool.go:1579–1618

(ctx context.Context, conns []*Conn, reason string)

}

func (p *ConnPool) RetireConns(ctx context.Context, conns []*Conn, reason string) {
	if len(conns) == 0 {
		return
	}

	idleConnSet := make(map[*Conn]struct{})
	toClose := make([]*Conn, 0, len(conns))

	p.connsMu.Lock()
	for _, ic := range p.idleConns {
		idleConnSet[ic] = struct{}{}
	}
	for _, cn := range conns {
		if cn == nil {
			continue
		}
		if _, ok := p.conns[cn.GetID()]; !ok {
			continue
		}
		if _, isIdle := idleConnSet[cn]; isIdle {
			if p.removeConn(cn) {
				toClose = append(toClose, cn)
			}
			continue
		}
		cn.MarkCloseOnPut(reason)
	}
	p.connsMu.Unlock()

	if hookManager := p.hookManager.Load(); hookManager != nil {
		for _, cn := range toClose {
			hookManager.ProcessOnRemove(ctx, cn, errors.New(reason))
		}
	}
	for _, cn := range toClose {
		p.recordConnectionMetrics(ctx, cn, reason, MetricStateIdle)
		_ = p.closeConn(cn)
	}
	p.checkMinIdleConns()
}

func (p *ConnPool) Filter(fn func(*Conn) bool) error {
	ctx := context.Background()