(a net.Addr)
| 843 | } |
| 844 | |
| 845 | func (p *connPool) newConnGroup(a net.Addr) *connGroup { |
| 846 | return &connGroup{ |
| 847 | addr: a, |
| 848 | pool: p, |
| 849 | broker: Broker{ |
| 850 | ID: -1, |
| 851 | }, |
| 852 | } |
| 853 | } |
| 854 | |
| 855 | func (p *connPool) newBrokerConnGroup(broker Broker) *connGroup { |
| 856 | return &connGroup{ |