type ccBalancerWrapper …
func newCCBalancerWrapper(cc *ClientConn) *ccBalancerWrapper { … }
func (ccb *ccBalancerWrapper) updateClientConnState(ccs *balancer.ClientConnState) error { … }
func (ccb *ccBalancerWrapper) resolverError(err error) { … }
func (ccb *ccBalancerWrapper) close() { … }
func (ccb *ccBalancerWrapper) exitIdle() { … }
func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) { … }
func (ccb *ccBalancerWrapper) RemoveSubConn(sc balancer.SubConn) { … }
func (ccb *ccBalancerWrapper) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) { … }
func (ccb *ccBalancerWrapper) UpdateState(s balancer.State) { … }
func (ccb *ccBalancerWrapper) ResolveNow(o resolver.ResolveNowOptions) { … }
func (ccb *ccBalancerWrapper) Target() string { … }
type acBalancerWrapper …
func (acbw *acBalancerWrapper) updateState(s connectivity.State, err error) { … }
func (acbw *acBalancerWrapper) String() string { … }
func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) { … }
func (acbw *acBalancerWrapper) Connect() { … }
func (acbw *acBalancerWrapper) Shutdown() { … }
func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) { … }
func (acbw *acBalancerWrapper) Invoke(ctx context.Context, method string, args any, reply any, opts ...CallOption) error { … }
type refCountedProducer …
func (acbw *acBalancerWrapper) GetOrBuildProducer(pb balancer.ProducerBuilder) (balancer.Producer, func()) { … }