const ErrorCodeKeyNotFound … const ErrorCodeTestFailed … const ErrorCodeNotFile … const ErrorCodeNotDir … const ErrorCodeNodeExist … const ErrorCodeRootROnly … const ErrorCodeDirNotEmpty … const ErrorCodeUnauthorized … const ErrorCodePrevValueRequired … const ErrorCodeTTLNaN … const ErrorCodeIndexNaN … const ErrorCodeInvalidField … const ErrorCodeInvalidForm … const ErrorCodeRaftInternal … const ErrorCodeLeaderElect … const ErrorCodeWatcherCleared … const ErrorCodeEventIndexCleared … type Error … func (e Error) Error() string { … } var ErrInvalidJSON … var ErrEmptyBody … type PrevExistType … const PrevIgnore … const PrevExist … const PrevNoExist … var defaultV2KeysPrefix … // NewKeysAPI builds a KeysAPI that interacts with etcd's key-value // API over HTTP. func NewKeysAPI(c Client) KeysAPI { … } // NewKeysAPIWithPrefix acts like NewKeysAPI, but allows the caller // to provide a custom base URL path. This should only be used in // very rare cases. func NewKeysAPIWithPrefix(c Client, p string) KeysAPI { … } type KeysAPI … type WatcherOptions … type CreateInOrderOptions … type SetOptions … type GetOptions … type DeleteOptions … type Watcher … type Response … type Node … func (n *Node) String() string { … } // TTLDuration returns the Node's TTL as a time.Duration object func (n *Node) TTLDuration() time.Duration { … } type Nodes … func (ns Nodes) Len() int { … } func (ns Nodes) Less(i, j int) bool { … } func (ns Nodes) Swap(i, j int) { … } type httpKeysAPI … func (k *httpKeysAPI) Set(ctx context.Context, key, val string, opts *SetOptions) (*Response, error) { … } func (k *httpKeysAPI) Create(ctx context.Context, key, val string) (*Response, error) { … } func (k *httpKeysAPI) CreateInOrder(ctx context.Context, dir, val string, opts *CreateInOrderOptions) (*Response, error) { … } func (k *httpKeysAPI) Update(ctx context.Context, key, val string) (*Response, error) { … } func (k *httpKeysAPI) Delete(ctx context.Context, key string, opts *DeleteOptions) (*Response, error) { … } func (k *httpKeysAPI) Get(ctx context.Context, key string, opts *GetOptions) (*Response, error) { … } func (k *httpKeysAPI) Watcher(key string, opts *WatcherOptions) Watcher { … } type httpWatcher … func (hw *httpWatcher) Next(ctx context.Context) (*Response, error) { … } // v2KeysURL forms a URL representing the location of a key. // The endpoint argument represents the base URL of an etcd // server. The prefix is the path needed to route from the // provided endpoint's path to the root of the keys API // (typically "/v2/keys"). func v2KeysURL(ep url.URL, prefix, key string) *url.URL { … } type getAction … func (g *getAction) HTTPRequest(ep url.URL) *http.Request { … } type waitAction … func (w *waitAction) HTTPRequest(ep url.URL) *http.Request { … } type setAction … func (a *setAction) HTTPRequest(ep url.URL) *http.Request { … } type deleteAction … func (a *deleteAction) HTTPRequest(ep url.URL) *http.Request { … } type createInOrderAction … func (a *createInOrderAction) HTTPRequest(ep url.URL) *http.Request { … } func unmarshalHTTPResponse(code int, header http.Header, body []byte) (res *Response, err error) { … } var jsonIterator … func unmarshalSuccessfulKeysResponse(header http.Header, body []byte) (*Response, error) { … } func unmarshalFailedKeysResponse(body []byte) error { … }
Codebase Browser
kubernetes