Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for CheckEtcdServers (0.82 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/etcd3/preflight/checks_test.go

    	etcd := new(EtcdConnection)
    	result, err := etcd.CheckEtcdServers()
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if result {
    		t.Fatal("CheckEtcdServers should not have succeeded")
    	}
    }
    
    func TestCheckEtcdServersUri(t *testing.T) {
    	etcd := new(EtcdConnection)
    	etcd.ServerList = []string{"-invalid uri$@#%"}
    	result, err := etcd.CheckEtcdServers()
    	if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 01 21:37:52 UTC 2017
    - 2.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/preflight/checks.go

    	if err != nil {
    		return &url.URL{}, fmt.Errorf("unable to parse etcd url: %v", err)
    	}
    	return connURL, nil
    }
    
    // CheckEtcdServers will attempt to reach all etcd servers once. If any
    // can be reached, return true.
    func (con EtcdConnection) CheckEtcdServers() (done bool, err error) {
    	// Attempt to reach every Etcd server randomly.
    	serverNumber := len(con.ServerList)
    	serverPerms := rand.Perm(serverNumber)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 20 10:50:48 UTC 2018
    - 1.8K bytes
    - Viewed (0)
Back to top