NewBalancerClientConn creates a BalancerClientConn.
(t *testing.T)
| 129 | |
| 130 | // NewBalancerClientConn creates a BalancerClientConn. |
| 131 | func NewBalancerClientConn(t *testing.T) *BalancerClientConn { |
| 132 | return &BalancerClientConn{ |
| 133 | logger: t, |
| 134 | |
| 135 | NewSubConnAddrsCh: make(chan []resolver.Address, 10), |
| 136 | NewSubConnCh: make(chan *TestSubConn, 10), |
| 137 | ShutdownSubConnCh: make(chan *TestSubConn, 10), |
| 138 | UpdateAddressesAddrsCh: make(chan []resolver.Address, 1), |
| 139 | |
| 140 | NewPickerCh: make(chan balancer.Picker, 1), |
| 141 | NewStateCh: make(chan connectivity.State, 1), |
| 142 | ResolveNowCh: make(chan resolver.ResolveNowOptions, 1), |
| 143 | } |
| 144 | } |
| 145 | |
| 146 | // NewSubConn creates a new SubConn. |
| 147 | func (tcc *BalancerClientConn) NewSubConn(a []resolver.Address, o balancer.NewSubConnOptions) (balancer.SubConn, error) { |
no outgoing calls