(addr string)
| 143 | } |
| 144 | |
| 145 | func (p *Pools) getPool(addr string) (*Pool, bool) { |
| 146 | p.RLock() |
| 147 | defer p.RUnlock() |
| 148 | existingPool, has := p.all[addr] |
| 149 | return existingPool, has |
| 150 | } |
| 151 | |
| 152 | // Connect creates a Pool instance for the node with the given address or returns the existing one. |
| 153 | func (p *Pools) Connect(addr string, tlsClientConf *tls.Config) *Pool { |