MCPcopy
hub / github.com/grpc/grpc-go / NewBalancerClientConn

Function NewBalancerClientConn

internal/testutils/balancer.go:131–144  ·  view source on GitHub ↗

NewBalancerClientConn creates a BalancerClientConn.

(t *testing.T)

Source from the content-addressed store, hash-verified

129
130// NewBalancerClientConn creates a BalancerClientConn.
131func 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.
147func (tcc *BalancerClientConn) NewSubConn(a []resolver.Address, o balancer.NewSubConnOptions) (balancer.SubConn, error) {

Calls

no outgoing calls