Anthony Romano 219a4e9ad5 clientv3: don't reset keepalive stream on grant failure | 8 years ago | |
---|---|---|
.. | ||
concurrency | 8 years ago | |
integration | 8 years ago | |
mirror | 8 years ago | |
README.md | 8 years ago | |
auth.go | 8 years ago | |
balancer.go | 8 years ago | |
client.go | 8 years ago | |
client_test.go | 8 years ago | |
cluster.go | 8 years ago | |
compact_op.go | 8 years ago | |
compact_op_test.go | 8 years ago | |
compare.go | 8 years ago | |
config.go | 8 years ago | |
config_test.go | 8 years ago | |
doc.go | 8 years ago | |
example_auth_test.go | 8 years ago | |
example_cluster_test.go | 8 years ago | |
example_kv_test.go | 8 years ago | |
example_lease_test.go | 8 years ago | |
example_maintenence_test.go | 8 years ago | |
example_test.go | 8 years ago | |
example_watch_test.go | 8 years ago | |
kv.go | 8 years ago | |
lease.go | 8 years ago | |
logger.go | 8 years ago | |
main_test.go | 8 years ago | |
maintenance.go | 8 years ago | |
op.go | 8 years ago | |
retry.go | 8 years ago | |
sort.go | 8 years ago | |
txn.go | 8 years ago | |
txn_test.go | 8 years ago | |
watch.go | 8 years ago | |
watch_test.go | 8 years ago |
etcd/clientv3
is the official Go etcd client for v3.
go get github.com/coreos/etcd/clientv3
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 cmd/vendor
directory to store external dependencies, which are
to be compiled into etcd release binaries. client
can be imported without
vendoring. For full compatibility, it is recommended to vendor builds using
etcd's vendored packages, using tools like godep, as in
vendor directories.
For more detail, please read Go vendor design.
etcd client returns 2 types of errors:
Here is the example code to handle client errors:
resp, err := kvc.Put(ctx, "", "")
if err != nil {
switch err {
case context.Canceled:
log.Fatalf("ctx is canceled by another routine: %v", err)
case context.DeadlineExceeded:
log.Fatalf("ctx is attached with a deadline is exceeded: %v", err)
case rpctypes.ErrEmptyKey:
log.Fatalf("client-side error: %v", err)
default:
log.Fatalf("bad cluster endpoints, which are not etcd servers: %v", err)
}
}
More code examples can be found at GoDoc.