etcd/clientv3
Sahdev Zala e16abdfade
Merge pull request #9115 from gyuho/doc-watch
clientv3: document possible memory pile-up in Watch
2018-01-11 18:12:13 -05:00
..
clientv3util clientv3: goword spelling check 2017-09-06 22:11:33 -07:00
concurrency *: make receiver names consistent 2017-09-12 03:54:04 -07:00
integration StatusFromError: handle return value of the function 2018-01-08 22:28:20 -05:00
leasing StatusFromError: handle return value of the function 2018-01-08 22:28:20 -05:00
mirror *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
namespace *: make receiver names consistent 2017-09-12 03:54:04 -07:00
naming api/v3rpc: deprecate grpc.Errorf 2017-11-04 22:08:17 -07:00
ordering clientv3: call KV/Txn APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
yaml clientv3/yaml: add 'TrustedCAfile' field to replace 'CAfile' 2017-10-04 14:00:54 -07:00
README.md clientv3: fix godoc badge link 2017-08-25 17:44:36 -07:00
auth.go clientv3: call other APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
client.go StatusFromError: handle return value of the function 2018-01-08 22:28:20 -05:00
client_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
cluster.go clientv3: call other APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
compact_op.go clientv3: goword spelling check 2017-09-06 22:11:33 -07:00
compact_op_test.go clientv3: configurable physical in compact 2016-06-27 12:04:04 -07:00
compare.go clientv3: Allow naked LeaseID or int64 for LeaseValue Compare's 2017-09-07 13:49:35 -04:00
config.go clientv3: configure gRPC message limits in Config 2017-12-20 10:58:01 -08:00
doc.go clientv3: fix indentation in doc.go 2017-12-04 17:05:31 -08:00
example_auth_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
example_cluster_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
example_kv_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
example_lease_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
example_maintenence_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
example_metrics_test.go words: whitelist prometheus 2017-11-10 10:08:48 -08:00
example_test.go clientv3: upgrade grpclog to LoggerV2 2017-09-08 15:25:32 -07:00
example_watch_test.go *: replace 'golang.org/x/net/context' with 'context' 2017-09-07 13:39:42 -07:00
grpc_options.go clientv3: configure gRPC message limits in Config 2017-12-20 10:58:01 -08:00
health_balancer.go clientv3: simplify V(4) logger with Lvl(4) 2017-12-05 18:48:36 -08:00
health_balancer_test.go clientv3/balancer: only notify healthy addresses 2017-11-10 15:39:25 -08:00
kv.go clientv3: call KV/Txn APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
lease.go clientv3: call other APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
logger.go clientv3: add Lvl method to logger 2017-12-05 18:48:36 -08:00
logger_test.go clientv3: add Lvl method to logger 2017-12-05 18:48:36 -08:00
main_test.go *: fix 'ineffassign' issues 2017-10-03 10:14:33 -07:00
maintenance.go Merge pull request #9024 from gyuho/snapshot-doc 2017-12-21 12:44:40 -08:00
op.go clientv3: goword spelling check 2017-09-06 22:11:33 -07:00
op_test.go clientv3: ignore sort-ascend-key option 2016-08-04 11:13:41 -07:00
ready_wait.go clientv3: separate readyWait for ConnectNotify 2017-10-19 13:07:22 -07:00
retry.go StatusFromError: handle return value of the function 2018-01-08 22:28:20 -05:00
sort.go clientv3: update LICENSE header 2016-05-12 20:50:58 -07:00
txn.go clientv3: call KV/Txn APIs with default gRPC call options 2017-12-20 10:58:05 -08:00
txn_test.go testutil, clientv3: wait for panics in txn tests to complete 2016-07-18 09:37:33 -07:00
watch.go clientv3: document possible memory pile-up in Watch 2018-01-08 10:37:47 -08:00
watch_test.go clientv3: check IsModify 2017-05-05 19:39:59 +02:00

README.md

etcd/clientv3

Godoc

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 := cli.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.

Error Handling

etcd client returns 2 types of errors:

  1. context error: canceled or deadline exceeded.
  2. gRPC error: see api/v3rpc/rpctypes.

Here is the example code to handle client errors:

resp, err := cli.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)
	}
}

Metrics

The etcd client optionally exposes RPC metrics through go-grpc-prometheus. See the examples.

Namespacing

The namespace package provides clientv3 interface wrappers to transparently isolate client requests to a user-defined prefix.

Examples

More code examples can be found at GoDoc.