Versions in this module Expand all Collapse all v1 v1.0.0 Jun 24, 2021 Changes in this version + const DefaultChanBufferSize + const DefaultChanRecvTimeout + var ErrRecvTimeout = errors.New("timed out when waiting for value on channel") + var ErrTestConstPicker = fmt.Errorf("const picker error") + var TestSubConns []*TestSubConn + func IsRoundRobin(want []balancer.SubConn, f func() balancer.SubConn) error + func NewTestWRR() wrr.WRR + type Channel struct + func NewChannel() *Channel + func NewChannelWithSize(bufSize int) *Channel + func (cwt *Channel) Receive() (interface{}, error) + func (cwt *Channel) Send(value interface{}) + func (cwt *Channel) TimedReceive(timeout time.Duration) (interface{}, error) + type TestClientConn struct + NewPickerCh chan balancer.V2Picker + NewStateCh chan connectivity.State + NewSubConnAddrsCh chan []resolver.Address + NewSubConnCh chan balancer.SubConn + RemoveSubConnCh chan balancer.SubConn + func NewTestClientConn(t *testing.T) *TestClientConn + func (tcc *TestClientConn) NewSubConn(a []resolver.Address, o balancer.NewSubConnOptions) (balancer.SubConn, error) + func (tcc *TestClientConn) RemoveSubConn(sc balancer.SubConn) + func (tcc *TestClientConn) ResolveNow(resolver.ResolveNowOptions) + func (tcc *TestClientConn) Target() string + func (tcc *TestClientConn) UpdateBalancerState(s connectivity.State, p balancer.Picker) + func (tcc *TestClientConn) UpdateState(bs balancer.State) + type TestConstBalancerBuilder struct + func (*TestConstBalancerBuilder) Build(cc balancer.ClientConn, opts balancer.BuildOptions) balancer.Balancer + func (*TestConstBalancerBuilder) Name() string + type TestConstPicker struct + Err error + SC balancer.SubConn + func (tcp *TestConstPicker) Pick(info balancer.PickInfo) (balancer.PickResult, error) + type TestLoadStore struct + CallsCost []TestServerLoad + CallsEnded []internal.Locality + CallsStarted []internal.Locality + func NewTestLoadStore() *TestLoadStore + func (*TestLoadStore) CallDropped(category string) + func (*TestLoadStore) ReportTo(ctx context.Context, cc *grpc.ClientConn, clusterName string, ...) + func (tls *TestLoadStore) CallFinished(l internal.Locality, err error) + func (tls *TestLoadStore) CallServerLoad(l internal.Locality, name string, d float64) + func (tls *TestLoadStore) CallStarted(l internal.Locality) + type TestServerLoad struct + D float64 + Name string + type TestSubConn struct + func (tsc *TestSubConn) Connect() + func (tsc *TestSubConn) String() string + func (tsc *TestSubConn) UpdateAddresses([]resolver.Address)