Gyu-Ho Lee 8f3981c651 Merge pull request #4612 from gyuho/watch_not_panic %!s(int64=10) %!d(string=hai) anos
..
concurrency ed44bb00f8 etcdctlv3: lock command %!s(int64=10) %!d(string=hai) anos
integration a78604dacb *: watch true cancel, created for wrong rev %!s(int64=10) %!d(string=hai) anos
mirror 9f569842f0 clientv3: move syncer to mirror package %!s(int64=10) %!d(string=hai) anos
README.md 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
client.go c5b51946eb *: exported godoc fixups %!s(int64=10) %!d(string=hai) anos
client_test.go 71c2a9bb3c *: fix minor typos, comments %!s(int64=10) %!d(string=hai) anos
cluster.go b19d57e1c3 clientv3: fix godoc for member apis %!s(int64=10) %!d(string=hai) anos
compare.go 4f41d361a8 clientv3: make compare compliant with proposed txn usage %!s(int64=10) %!d(string=hai) anos
doc.go 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
example_cluster_test.go 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
example_kv_test.go 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
example_lease_test.go 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
example_test.go 72a1e5618b clientv3: add more code examples %!s(int64=10) %!d(string=hai) anos
example_watch_test.go a24d276891 clientv3: combine Watch, WatchPrefix with variadic %!s(int64=10) %!d(string=hai) anos
kv.go afa0368dcc *: fix godoc bugs in interfaces and slice fields %!s(int64=10) %!d(string=hai) anos
lease.go afa0368dcc *: fix godoc bugs in interfaces and slice fields %!s(int64=10) %!d(string=hai) anos
op.go d4b2044eb1 clientv3/concurrency: Mutex %!s(int64=10) %!d(string=hai) anos
sort.go 2d2f14385d clientv3: fill in kv ops %!s(int64=10) %!d(string=hai) anos
txn.go 7b82576b60 clientv3: copy correct pointers into txn comparisons %!s(int64=10) %!d(string=hai) anos
txn_test.go 3c9e8540a7 clientv3: optionize put and delete %!s(int64=10) %!d(string=hai) anos
watch.go a78604dacb *: watch true cancel, created for wrong rev %!s(int64=10) %!d(string=hai) anos

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:12378", "localhost:22378", "localhost:32378"},
	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

Error Handling

TODO

Examples

More code examples can be found at GoDoc.