Documentation ¶
Index ¶
- Constants
- Variables
- func DefaultCheckRetry(cluster *Cluster, numReqs int, lastResp http.Response, err error) error
- func GetLogger() *log.Logger
- func SetLogger(l *log.Logger)
- type Client
- func (c *Client) AddChild(key string, value string, ttl uint64) (*Response, error)
- func (c *Client) AddChildDir(key string, ttl uint64) (*Response, error)
- func (c *Client) AddRootCA(caCert string) error
- func (c *Client) Close()
- func (c *Client) CloseCURL()
- func (c *Client) CompareAndDelete(key string, prevValue string, prevIndex uint64) (*Response, error)
- func (c *Client) CompareAndSwap(key string, value string, ttl uint64, prevValue string, prevIndex uint64) (*Response, error)
- func (c *Client) Create(key string, value string, ttl uint64) (*Response, error)
- func (c *Client) CreateDir(key string, ttl uint64) (*Response, error)
- func (c *Client) CreateInOrder(dir string, value string, ttl uint64) (*Response, error)
- func (c *Client) DefaultDial(network, addr string) (net.Conn, error)
- func (c *Client) Delete(key string, recursive bool) (*Response, error)
- func (c *Client) DeleteDir(key string) (*Response, error)
- func (c *Client) Get(key string, sort, recursive bool) (*Response, error)
- func (c *Client) GetCluster() []string
- func (c *Client) MarshalJSON() ([]byte, error)
- func (c *Client) OpenCURL()
- func (c *Client) RawCompareAndDelete(key string, prevValue string, prevIndex uint64) (*RawResponse, error)
- func (c *Client) RawCompareAndSwap(key string, value string, ttl uint64, prevValue string, prevIndex uint64) (*RawResponse, error)
- func (c *Client) RawCreate(key string, value string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawCreateDir(key string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawCreateInOrder(dir string, value string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawDelete(key string, recursive bool, dir bool) (*RawResponse, error)
- func (c *Client) RawGet(key string, sort, recursive bool) (*RawResponse, error)
- func (c *Client) RawSet(key string, value string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawSetDir(key string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawUpdate(key string, value string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawUpdateDir(key string, ttl uint64) (*RawResponse, error)
- func (c *Client) RawWatch(prefix string, waitIndex uint64, recursive bool, receiver chan *RawResponse, ...) (*RawResponse, error)
- func (c *Client) RecvCURL() string
- func (c *Client) SendRequest(rr *RawRequest) (*RawResponse, error)
- func (c *Client) Set(key string, value string, ttl uint64) (*Response, error)
- func (c *Client) SetCluster(machines []string) bool
- func (c *Client) SetConsistency(consistency string) error
- func (c *Client) SetCredentials(username, password string)
- func (c *Client) SetDialTimeout(d time.Duration)
- func (c *Client) SetDir(key string, ttl uint64) (*Response, error)
- func (c *Client) SetPersistence(writer io.Writer)
- func (c *Client) SetTransport(tr *http.Transport)
- func (c *Client) SyncCluster() bool
- func (c *Client) UnmarshalJSON(b []byte) error
- func (c *Client) Update(key string, value string, ttl uint64) (*Response, error)
- func (c *Client) UpdateDir(key string, ttl uint64) (*Response, error)
- func (c *Client) Watch(prefix string, waitIndex uint64, recursive bool, receiver chan *Response, ...) (*Response, error)
- type Cluster
- type Config
- type EtcdError
- type Member
- type Node
- type Nodes
- type Options
- type RawRequest
- type RawResponse
- type Response
Constants ¶
const ( // Using strings rather than iota because the consistency level // could be persisted to disk, so it'd be better to use // human-readable values. STRONG_CONSISTENCY = "STRONG" WEAK_CONSISTENCY = "WEAK" )
See SetConsistency for how to use these constants.
const ( ErrCodeEtcdNotReachable = 501 ErrCodeUnhandledHTTPStatus = 502 )
Variables ¶
var ( VALID_GET_OPTIONS = validOptions{ "recursive": reflect.Bool, "quorum": reflect.Bool, "sorted": reflect.Bool, "wait": reflect.Bool, "waitIndex": reflect.Uint64, } VALID_PUT_OPTIONS = validOptions{ "prevValue": reflect.String, "prevIndex": reflect.Uint64, "prevExist": reflect.Bool, "dir": reflect.Bool, } VALID_POST_OPTIONS = validOptions{} VALID_DELETE_OPTIONS = validOptions{ "recursive": reflect.Bool, "dir": reflect.Bool, "prevValue": reflect.String, "prevIndex": reflect.Uint64, } )
Valid options for GET, PUT, POST, DELETE Using CAPITALIZED_UNDERSCORE to emphasize that these values are meant to be used as constants.
var (
ErrRequestCancelled = errors.New("sending request is cancelled")
)
Errors introduced by handling requests
var (
ErrWatchStoppedByUser = errors.New("Watch stopped by the user via stop channel")
)
Errors introduced by the Watch command.
Functions ¶
func DefaultCheckRetry ¶
DefaultCheckRetry defines the retrying behaviour for bad HTTP requests If we have retried 2 * machine number, stop retrying. If status code is InternalServerError, sleep for 200ms.
Types ¶
type Client ¶
type Client struct { // CheckRetry can be used to control the policy for failed requests // and modify the cluster if needed. // The client calls it before sending requests again, and // stops retrying if CheckRetry returns some error. The cases that // this function needs to handle include no response and unexpected // http status code of response. // If CheckRetry is nil, client will call the default one // `DefaultCheckRetry`. // Argument cluster is the etcd.Cluster object that these requests have been made on. // Argument numReqs is the number of http.Requests that have been made so far. // Argument lastResp is the http.Responses from the last request. // Argument err is the reason of the failure. CheckRetry func(cluster *Cluster, numReqs int, lastResp http.Response, err error) error // contains filtered or unexported fields }
func NewClient ¶
NewClient create a basic client that is configured to be used with the given machine list.
func NewClientFromFile ¶
NewClientFromFile creates a client from a given file path. The given file is expected to use the JSON format.
func NewClientFromReader ¶
NewClientFromReader creates a Client configured from a given reader. The configuration is expected to use the JSON format.
func NewTLSClient ¶
NewTLSClient create a basic client with TLS configuration
func (*Client) AddChildDir ¶
Add a new directory with a random etcd-generated key under the given path.
func (*Client) CompareAndDelete ¶
func (*Client) CompareAndSwap ¶
func (*Client) Create ¶
Create creates a file with the given value under the given key. It succeeds only if the given key does not yet exist.
func (*Client) CreateDir ¶
CreateDir creates a directory. It succeeds only if the given key does not yet exist.
func (*Client) CreateInOrder ¶
CreateInOrder creates a file with a key that's guaranteed to be higher than other keys in the given directory. It is useful for creating queues.
func (*Client) DefaultDial ¶ added in v1.2.0
DefaultDial attempts to open a TCP connection to the provided address, explicitly enabling keep-alives with a one-second interval.
func (*Client) Delete ¶
Delete deletes the given key.
When recursive set to false, if the key points to a directory the method will fail.
When recursive set to true, if the key points to a file, the file will be deleted; if the key points to a directory, then everything under the directory (including all child directories) will be deleted.
func (*Client) Get ¶
Get gets the file or directory associated with the given key. If the key points to a directory, files and directories under it will be returned in sorted or unsorted order, depending on the sort flag. If recursive is set to false, contents under child directories will not be returned. If recursive is set to true, all the contents will be returned.
func (*Client) GetCluster ¶
func (*Client) MarshalJSON ¶
MarshalJSON implements the Marshaller interface as defined by the standard JSON package.
func (*Client) RawCompareAndDelete ¶
func (*Client) RawCompareAndSwap ¶
func (*Client) RawCreateDir ¶
func (c *Client) RawCreateDir(key string, ttl uint64) (*RawResponse, error)
func (*Client) RawCreateInOrder ¶
func (*Client) RawGet ¶
func (c *Client) RawGet(key string, sort, recursive bool) (*RawResponse, error)
func (*Client) RawUpdateDir ¶
func (c *Client) RawUpdateDir(key string, ttl uint64) (*RawResponse, error)
func (*Client) RawWatch ¶
func (c *Client) RawWatch(prefix string, waitIndex uint64, recursive bool, receiver chan *RawResponse, stop chan bool) (*RawResponse, error)
func (*Client) SendRequest ¶
func (c *Client) SendRequest(rr *RawRequest) (*RawResponse, error)
SendRequest sends a HTTP request and returns a Response as defined by etcd
func (*Client) Set ¶
Set sets the given key to the given value. It will create a new key value pair or replace the old one. It will not replace a existing directory.
func (*Client) SetCluster ¶
SetCluster updates cluster information using the given machine list.
func (*Client) SetConsistency ¶
SetConsistency changes the consistency level of the client.
When consistency is set to STRONG_CONSISTENCY, all requests, including GET, are sent to the leader. This means that, assuming the absence of leader failures, GET requests are guaranteed to see the changes made by previous requests.
When consistency is set to WEAK_CONSISTENCY, other requests are still sent to the leader, but GET requests are sent to a random server from the server pool. This reduces the read load on the leader, but it's not guaranteed that the GET requests will see changes made by previous requests (they might have not yet been committed on non-leader servers).
func (*Client) SetCredentials ¶ added in v0.16.0
func (*Client) SetDialTimeout ¶
Sets the DialTimeout value
func (*Client) SetDir ¶
SetDir sets the given key to a directory. It will create a new directory or replace the old key value pair by a directory. It will not replace a existing directory.
func (*Client) SetPersistence ¶
SetPersistence sets a writer to which the config will be written every time it's changed.
func (*Client) SetTransport ¶
Override the Client's HTTP Transport object
func (*Client) SyncCluster ¶
SyncCluster updates the cluster information using the internal machine list. If no members are found, the intenral machine list is left untouched.
func (*Client) UnmarshalJSON ¶
UnmarshalJSON implements the Unmarshaller interface as defined by the standard JSON package.
func (*Client) Update ¶
Update updates the given key to the given value. It succeeds only if the given key already exists.
func (*Client) UpdateDir ¶
UpdateDir updates the given directory. It succeeds only if the given key already exists.
func (*Client) Watch ¶
func (c *Client) Watch(prefix string, waitIndex uint64, recursive bool, receiver chan *Response, stop chan bool) (*Response, error)
If recursive is set to true the watch returns the first change under the given prefix since the given index.
If recursive is set to false the watch returns the first change to the given key since the given index.
To watch for the latest change, set waitIndex = 0.
If a receiver channel is given, it will be a long-term watch. Watch will block at the channel. After someone receives the channel, it will go on to watch that prefix. If a stop channel is given, the client can close long-term watch using the stop channel.
type Cluster ¶
type Cluster struct { Leader string `json:"leader"` Machines []string `json:"machines"` // contains filtered or unexported fields }
func NewCluster ¶
type EtcdError ¶
type Node ¶
type Node struct { Key string `json:"key, omitempty"` Value string `json:"value,omitempty"` Dir bool `json:"dir,omitempty"` Expiration *time.Time `json:"expiration,omitempty"` TTL int64 `json:"ttl,omitempty"` Nodes Nodes `json:"nodes,omitempty"` ModifiedIndex uint64 `json:"modifiedIndex,omitempty"` CreatedIndex uint64 `json:"createdIndex,omitempty"` }
func (*Node) CodecDecodeSelf ¶ added in v0.20.0
func (*Node) CodecEncodeSelf ¶ added in v0.20.0
type Nodes ¶
type Nodes []*Node
func (*Nodes) CodecDecodeSelf ¶ added in v0.20.0
func (Nodes) CodecEncodeSelf ¶ added in v0.20.0
type RawRequest ¶
func NewRawRequest ¶
func NewRawRequest(method, relativePath string, values url.Values, cancel <-chan bool) *RawRequest
NewRawRequest returns a new RawRequest
type RawResponse ¶
func (*RawResponse) CodecDecodeSelf ¶ added in v0.20.0
func (x *RawResponse) CodecDecodeSelf(d *codec1978.Decoder)
func (*RawResponse) CodecEncodeSelf ¶ added in v0.20.0
func (x *RawResponse) CodecEncodeSelf(e *codec1978.Encoder)
func (*RawResponse) Unmarshal ¶
func (rr *RawResponse) Unmarshal() (*Response, error)
Unmarshal parses RawResponse and stores the result in Response
type Response ¶
type Response struct { Action string `json:"action"` Node *Node `json:"node"` PrevNode *Node `json:"prevNode,omitempty"` EtcdIndex uint64 `json:"etcdIndex"` RaftIndex uint64 `json:"raftIndex"` RaftTerm uint64 `json:"raftTerm"` }