|
@@ -301,7 +301,7 @@ func (c *httpClusterClient) SetEndpoints(eps []string) error {
|
|
|
// If endpoints doesn't have the lu, just keep c.pinned = 0.
|
|
// If endpoints doesn't have the lu, just keep c.pinned = 0.
|
|
|
// Forwarding between follower and leader would be required but it works.
|
|
// Forwarding between follower and leader would be required but it works.
|
|
|
default:
|
|
default:
|
|
|
- return errors.New(fmt.Sprintf("invalid endpoint selection mode: %d", c.selectionMode))
|
|
|
|
|
|
|
+ return fmt.Errorf("invalid endpoint selection mode: %d", c.selectionMode)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
return nil
|
|
@@ -393,7 +393,7 @@ func (c *httpClusterClient) Sync(ctx context.Context) error {
|
|
|
c.Lock()
|
|
c.Lock()
|
|
|
defer c.Unlock()
|
|
defer c.Unlock()
|
|
|
|
|
|
|
|
- eps := make([]string, 0)
|
|
|
|
|
|
|
+ var eps []string
|
|
|
for _, m := range ms {
|
|
for _, m := range ms {
|
|
|
eps = append(eps, m.ClientURLs...)
|
|
eps = append(eps, m.ClientURLs...)
|
|
|
}
|
|
}
|