Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ListMembers (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top