github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-15 14:14:39 +00:00
Code Issues Projects Releases Wiki Activity

check etcd servers by a random order

Browse Source
This commit is contained in:
hzxuzhonghu
2018-03-15 10:04:40 +08:00
parent 02611149c1
commit ea627f9875
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
staging/src/k8s.io/apiserver/pkg/storage/etcd3/preflight/checks.go
View File

@@ -18,6 +18,7 @@ package preflight
import ( import (
"fmt" "fmt"
"math/rand"
"net" "net"
"net/url" "net/url"
"time" "time"
@@ -59,9 +60,11 @@ func parseServerURI(serverURI string) (*url.URL, error) {
// CheckEtcdServers will attempt to reach all etcd servers once. If any // CheckEtcdServers will attempt to reach all etcd servers once. If any
// can be reached, return true. // can be reached, return true.
func (con EtcdConnection) CheckEtcdServers() (done bool, err error) { func (con EtcdConnection) CheckEtcdServers() (done bool, err error) {
// Attempt to reach every Etcd server in order // Attempt to reach every Etcd server randomly.
for _, serverURI := range con.ServerList { serverNumber := len(con.ServerList)
host, err := parseServerURI(serverURI) serverPerms := rand.Perm(serverNumber)
for _, index := range serverPerms {
host, err := parseServerURI(con.ServerList[index])
if err != nil { if err != nil {
return false, err return false, err
} }