Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ListMembers (0.11 sec)

  1. cmd/kubeadm/app/util/etcd/etcd_test.go

    				c.listMembersFunc = func(_ time.Duration) (*clientv3.MemberListResponse, error) {
    					return c.listMembers(100 * time.Millisecond)
    				}
    			}
    			got, err := c.ListMembers()
    			if !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("ListMembers() = %v, want %v", got, tt.want)
    			}
    			if (err != nil) != (tt.wantError) {
    				t.Errorf("ListMembers() error = %v, wantError %v", err, tt.wantError)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 14 13:07:56 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/etcd/etcd.go

    	}
    
    	for _, member := range resp.Members {
    		if member.GetPeerURLs()[0] == peerURL {
    			return member.GetID(), nil
    		}
    	}
    	return 0, ErrNoMemberIDForPeerURL
    }
    
    // ListMembers returns the member list.
    func (c *Client) ListMembers() ([]Member, error) {
    	resp, err := c.listMembersFunc(0)
    	if err != nil {
    		return nil, err
    	}
    
    	ret := make([]Member, 0, len(resp.Members))
    	for _, m := range resp.Members {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/phases/upgrade/staticpods_test.go

    	return true, nil
    }
    
    func (c fakeTLSEtcdClient) CheckClusterHealth() error {
    	return nil
    }
    
    func (c fakeTLSEtcdClient) Sync() error { return nil }
    
    func (c fakeTLSEtcdClient) ListMembers() ([]etcdutil.Member, error) {
    	return []etcdutil.Member{}, nil
    }
    
    func (c fakeTLSEtcdClient) AddMemberAsLearner(name string, peerAddrs string) ([]etcdutil.Member, error) {
    	return []etcdutil.Member{}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 32K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/phases/etcd/local.go

    	klog.V(1).Info("[etcd] creating etcd client that connects to etcd pods")
    	etcdClient, err := etcdutil.NewFromCluster(client, cfg.CertificatesDir)
    	if err != nil {
    		return err
    	}
    
    	members, err := etcdClient.ListMembers()
    	if err != nil {
    		return err
    	}
    	// If this is the only remaining stacked etcd member in the cluster, calling RemoveMember()
    	// is not needed.
    	if len(members) == 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 14:07:27 UTC 2024
    - 13.8K bytes
    - Viewed (1)
  5. CHANGELOG/CHANGELOG-1.23.md

    - Kubeadm: When adding an etcd peer to an existing cluster, if an error is returned indicating the peer has already been added, this is accepted and a `ListMembers` call is used instead to return the existing cluster. This helps to diminish the exponential backoff when the first AddMember call times out, while still retaining a similar performance when the peer has already been added from a previous call....
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 28 21:06:52 UTC 2023
    - 424.5K bytes
    - Viewed (0)
Back to top