mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
clientv3/balancer: change balancer name to builder name.
This commit is contained in:
parent
e1ca3b4434
commit
ddff08ffad
@ -54,7 +54,7 @@ func (b *builder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balan
|
|||||||
bb := &baseBalancer{
|
bb := &baseBalancer{
|
||||||
id: strconv.FormatInt(time.Now().UnixNano(), 36),
|
id: strconv.FormatInt(time.Now().UnixNano(), 36),
|
||||||
policy: b.cfg.Policy,
|
policy: b.cfg.Policy,
|
||||||
name: b.cfg.Policy.String(),
|
name: b.cfg.Name,
|
||||||
lg: b.cfg.Logger,
|
lg: b.cfg.Logger,
|
||||||
|
|
||||||
addrToSc: make(map[resolver.Address]balancer.SubConn),
|
addrToSc: make(map[resolver.Address]balancer.SubConn),
|
||||||
@ -67,9 +67,6 @@ func (b *builder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balan
|
|||||||
// initialize picker always returns "ErrNoSubConnAvailable"
|
// initialize picker always returns "ErrNoSubConnAvailable"
|
||||||
Picker: picker.NewErr(balancer.ErrNoSubConnAvailable),
|
Picker: picker.NewErr(balancer.ErrNoSubConnAvailable),
|
||||||
}
|
}
|
||||||
if b.cfg.Name != "" {
|
|
||||||
bb.name = b.cfg.Name
|
|
||||||
}
|
|
||||||
if bb.lg == nil {
|
if bb.lg == nil {
|
||||||
bb.lg = zap.NewNop()
|
bb.lg = zap.NewNop()
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user