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

var errNotImplemented …

type fakeEtcdClient …

// Close shuts down the client's etcd connections.
func (f *fakeEtcdClient) Close() error { … }

// Endpoints lists the registered endpoints for the client.
func (f *fakeEtcdClient) Endpoints() []string { … }

// MemberList lists the current cluster membership.
func (f *fakeEtcdClient) MemberList(_ context.Context) (*clientv3.MemberListResponse, error) { … }

// MemberAdd adds a new member into the cluster.
func (f *fakeEtcdClient) MemberAdd(_ context.Context, peerAddrs []string) (*clientv3.MemberAddResponse, error) { … }

// MemberAddAsLearner adds a new learner member into the cluster.
func (f *fakeEtcdClient) MemberAddAsLearner(_ context.Context, peerAddrs []string) (*clientv3.MemberAddResponse, error) { … }

// MemberRemove removes an existing member from the cluster.
func (f *fakeEtcdClient) MemberRemove(_ context.Context, id uint64) (*clientv3.MemberRemoveResponse, error) { … }

// MemberPromote promotes a member from raft learner (non-voting) to raft voting member.
func (f *fakeEtcdClient) MemberPromote(_ context.Context, id uint64) (*clientv3.MemberPromoteResponse, error) { … }

// Status gets the status of the endpoint.
func (f *fakeEtcdClient) Status(_ context.Context, endpoint string) (*clientv3.StatusResponse, error) { … }

// Sync synchronizes client's endpoints with the known endpoints from the etcd membership.
func (f *fakeEtcdClient) Sync(_ context.Context) error { … }

func testGetURL(t *testing.T, getURLFunc func(*kubeadmapi.APIEndpoint) string, port int) { … }

func TestGetClientURL(t *testing.T) { … }

func TestGetPeerURL(t *testing.T) { … }

func TestGetClientURLByIP(t *testing.T) { … }

func TestGetEtcdEndpointsWithBackoff(t *testing.T) { … }

func TestGetRawEtcdEndpointsFromPodAnnotation(t *testing.T) { … }

func TestGetRawEtcdEndpointsFromPodAnnotationWithoutRetry(t *testing.T) { … }

func TestClient_GetMemberID(t *testing.T) { … }

func TestListMembers(t *testing.T) { … }

func TestIsLearner(t *testing.T) { … }