testutils

Nov 18, 2021

Changes in this version

+ const TestSubConnsCount

+ var EmptyNodeProtoV2 = &v2corepb.Node

+ var EmptyNodeProtoV3 = &v3corepb.Node

+ var ErrTestConstPicker = fmt.Errorf("const picker error")

+ var TestSubConns []*TestSubConn

+ func IsRoundRobin(want []balancer.SubConn, f func() balancer.SubConn) error

+ func LocalityIDToProto(l internal.LocalityID) *v2corepb.Locality

+ func NewTestWRR() wrr.WRR

+ type AddLocalityOptions struct

+ Health []v2corepb.HealthStatus

+ Weight []uint32

+ type ClusterLoadAssignmentBuilder struct

+ func NewClusterLoadAssignmentBuilder(clusterName string, dropPercents map[string]uint32) *ClusterLoadAssignmentBuilder

+ func (clab *ClusterLoadAssignmentBuilder) AddLocality(subzone string, weight uint32, priority uint32, addrsWithPort []string, ...)

+ func (clab *ClusterLoadAssignmentBuilder) Build() *v2xdspb.ClusterLoadAssignment

+ type TestClientConn struct

+ NewPickerCh chan balancer.Picker

+ NewStateCh chan connectivity.State

+ NewSubConnAddrsCh chan []resolver.Address

+ NewSubConnCh chan balancer.SubConn

+ RemoveSubConnCh chan balancer.SubConn

+ ResolveNowCh chan resolver.ResolveNowOptions

+ UpdateAddressesAddrsCh chan []resolver.Address

+ 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(o resolver.ResolveNowOptions)

+ func (tcc *TestClientConn) Target() string

+ func (tcc *TestClientConn) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address)

+ func (tcc *TestClientConn) UpdateState(bs balancer.State)

+ func (tcc *TestClientConn) WaitForErrPicker(ctx context.Context) error

+ type TestConstPicker struct

+ Err error

+ SC balancer.SubConn

+ func (tcp *TestConstPicker) Pick(info balancer.PickInfo) (balancer.PickResult, error)

+ type TestSubConn struct

+ ConnectCh chan struct{}

+ func (tsc *TestSubConn) Connect()

+ func (tsc *TestSubConn) String() string

+ func (tsc *TestSubConn) UpdateAddresses([]resolver.Address)