(broker Broker)
| 853 | } |
| 854 | |
| 855 | func (p *connPool) newBrokerConnGroup(broker Broker) *connGroup { |
| 856 | return &connGroup{ |
| 857 | addr: &networkAddress{ |
| 858 | network: "tcp", |
| 859 | address: net.JoinHostPort(broker.Host, strconv.Itoa(broker.Port)), |
| 860 | }, |
| 861 | pool: p, |
| 862 | broker: broker, |
| 863 | } |
| 864 | } |
| 865 | |
| 866 | type connRequest struct { |
| 867 | ctx context.Context |