Versions in this module Expand all Collapse all v1 v1.42.11 Feb 5, 2024 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) v1.42.9-rc1 Feb 5, 2024
Go to main page