![]() etcdctlv3: initial implementaton of 'etcdctl member status' command |
||
---|---|---|
.. | ||
concurrency | ||
integration | ||
mirror | ||
README.md | ||
auth.go | ||
client.go | ||
client_test.go | ||
cluster.go | ||
compare.go | ||
config.go | ||
config_test.go | ||
doc.go | ||
example_cluster_test.go | ||
example_kv_test.go | ||
example_lease_test.go | ||
example_test.go | ||
example_watch_test.go | ||
kv.go | ||
lease.go | ||
logger.go | ||
maintenance.go | ||
op.go | ||
sort.go | ||
txn.go | ||
txn_test.go | ||
watch.go |
README.md
etcd/clientv3
etcd/clientv3
is the official Go etcd client for v3.
Install
go get github.com/coreos/etcd/clientv3
Get started
Create client using clientv3.New
:
cli, err := clientv3.New(clientv3.Config{
Endpoints: []string{"localhost:2379", "localhost:22379", "localhost:32379"},
DialTimeout: 5 * time.Second,
})
if err != nil {
// handle error!
}
defer cli.Close()
etcd v3 uses gRPC
for remote procedure calls. And clientv3
uses
grpc-go
to connect to etcd. Make sure to close the client after using it.
If the client is not closed, the connection will have leaky goroutines. To specify client request timeout,
pass context.WithTimeout
to APIs:
ctx, cancel := context.WithTimeout(context.Background(), timeout)
resp, err := kvc.Put(ctx, "sample_key", "sample_value")
cancel()
if err != nil {
// handle error!
}
// use the response
etcd uses go's vendor
directory to manage external dependencies. If clientv3
is imported
outside of etcd, simply copy clientv3
to the vendor
directory or use tools like godep to
manage your own dependency, as in vendor directories.
For more detail, please read Go vendor design.
Error Handling
etcd client returns 2 types of errors:
- context error: canceled or deadline exceeded.
- gRPC error: see v3rpc/error.
Here is the example code to handle client errors:
resp, err := kvc.Put(ctx, "", "")
if err != nil {
if err == context.Canceled {
// ctx is canceled by another routine
} else if err == context.DeadlineExceeded {
// ctx is attached with a deadline and it exceeded
} else if verr, ok := err.(*v3rpc.ErrEmptyKey); ok {
// process (verr.Errors)
} else {
// bad cluster endpoints, which are not etcd servers
}
}
Examples
More code examples can be found at GoDoc.