kubernetes/vendor/go.etcd.io/etcd/client/v2/members.go

var defaultV2MembersPrefix

var defaultLeaderSuffix

type Member

type memberCollection

func (c *memberCollection) UnmarshalJSON(data []byte) error {}

type memberCreateOrUpdateRequest

func (m *memberCreateOrUpdateRequest) MarshalJSON() ([]byte, error) {}

// NewMembersAPI constructs a new MembersAPI that uses HTTP to
// interact with etcd's membership API.
func NewMembersAPI(c Client) MembersAPI {}

type MembersAPI

type httpMembersAPI

func (m *httpMembersAPI) List(ctx context.Context) ([]Member, error) {}

func (m *httpMembersAPI) Add(ctx context.Context, peerURL string) (*Member, error) {}

func (m *httpMembersAPI) Update(ctx context.Context, memberID string, peerURLs []string) error {}

func (m *httpMembersAPI) Remove(ctx context.Context, memberID string) error {}

func (m *httpMembersAPI) Leader(ctx context.Context) (*Member, error) {}

type membersAPIActionList

func (l *membersAPIActionList) HTTPRequest(ep url.URL) *http.Request {}

type membersAPIActionRemove

func (d *membersAPIActionRemove) HTTPRequest(ep url.URL) *http.Request {}

type membersAPIActionAdd

func (a *membersAPIActionAdd) HTTPRequest(ep url.URL) *http.Request {}

type membersAPIActionUpdate

func (a *membersAPIActionUpdate) HTTPRequest(ep url.URL) *http.Request {}

func assertStatusCode(got int, want ...int) (err error) {}

type membersAPIActionLeader

func (l *membersAPIActionLeader) HTTPRequest(ep url.URL) *http.Request {}

// v2MembersURL add the necessary path to the provided endpoint
// to route requests to the default v2 members API.
func v2MembersURL(ep url.URL) *url.URL {}

type membersError

func (e membersError) Error() string {}