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