var logger … type baseBuilder … func (bb *baseBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer { … } func (bb *baseBuilder) Name() string { … } type baseBalancer … func (b *baseBalancer) ResolverError(err error) { … } func (b *baseBalancer) UpdateClientConnState(s balancer.ClientConnState) error { … } // mergeErrors builds an error from the last connection error and the last // resolver error. Must only be called if b.state is TransientFailure. func (b *baseBalancer) mergeErrors() error { … } // regeneratePicker takes a snapshot of the balancer, and generates a picker // from it. The picker is // - errPicker if the balancer is in TransientFailure, // - built by the pickerBuilder with all READY SubConns otherwise. func (b *baseBalancer) regeneratePicker() { … } // UpdateSubConnState is a nop because a StateListener is always set in NewSubConn. func (b *baseBalancer) UpdateSubConnState(sc balancer.SubConn, state balancer.SubConnState) { … } func (b *baseBalancer) updateSubConnState(sc balancer.SubConn, state balancer.SubConnState) { … } // Close is a nop because base balancer doesn't have internal state to clean up, // and it doesn't need to call Shutdown for the SubConns. func (b *baseBalancer) Close() { … } // ExitIdle is a nop because the base balancer attempts to stay connected to // all SubConns at all times. func (b *baseBalancer) ExitIdle() { … } // NewErrPicker returns a Picker that always returns err on Pick(). func NewErrPicker(err error) balancer.Picker { … } var NewErrPickerV2 … type errPicker … func (p *errPicker) Pick(info balancer.PickInfo) (balancer.PickResult, error) { … }
Codebase Browser
kubernetes