Gyu-Ho Lee 72a1e5618b clientv3: add more code examples пре 9 година
..
integration 11bb07c248 Merge pull request #4564 from heyitsanthony/fix-watchreconnrequest пре 9 година
sync 59291770d6 clientv3: WithPrefix operation option пре 9 година
README.md 72a1e5618b clientv3: add more code examples пре 9 година
client.go c5b51946eb *: exported godoc fixups пре 9 година
client_test.go 71c2a9bb3c *: fix minor typos, comments пре 10 година
cluster.go b19d57e1c3 clientv3: fix godoc for member apis пре 10 година
compare.go 4f41d361a8 clientv3: make compare compliant with proposed txn usage пре 10 година
doc.go 72a1e5618b clientv3: add more code examples пре 9 година
example_cluster_test.go 72a1e5618b clientv3: add more code examples пре 9 година
example_kv_test.go 72a1e5618b clientv3: add more code examples пре 9 година
example_lease_test.go 72a1e5618b clientv3: add more code examples пре 9 година
example_test.go 72a1e5618b clientv3: add more code examples пре 9 година
example_watch_test.go 72a1e5618b clientv3: add more code examples пре 9 година
kv.go 6851fffdfb clientv3: support >= Range requests пре 10 година
lease.go 50ad181477 clientv3: support context cancellation on lease keep alives пре 9 година
op.go 59291770d6 clientv3: WithPrefix operation option пре 9 година
sort.go 2d2f14385d clientv3: fill in kv ops пре 10 година
txn.go 7b82576b60 clientv3: copy correct pointers into txn comparisons пре 9 година
txn_test.go 3c9e8540a7 clientv3: optionize put and delete пре 10 година
watch.go f66162932c clientv3: fix current watcher reconnection пре 9 година

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.