- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ListMembers (0.15 sec)
-
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) -
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) -
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)