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 { … }
Codebase Browser
kubernetes