Hongchao Deng a19b30b7ab clientv3: kv.Delete typo 10 лет назад
..
integration 11bb07c248 Merge pull request #4564 from heyitsanthony/fix-watchreconnrequest 10 лет назад
sync 59291770d6 clientv3: WithPrefix operation option 10 лет назад
README.md 72a1e5618b clientv3: add more code examples 10 лет назад
client.go c5b51946eb *: exported godoc fixups 10 лет назад
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 10 лет назад
example_cluster_test.go 72a1e5618b clientv3: add more code examples 10 лет назад
example_kv_test.go 72a1e5618b clientv3: add more code examples 10 лет назад
example_lease_test.go 72a1e5618b clientv3: add more code examples 10 лет назад
example_test.go 72a1e5618b clientv3: add more code examples 10 лет назад
example_watch_test.go 72a1e5618b clientv3: add more code examples 10 лет назад
kv.go a19b30b7ab clientv3: kv.Delete typo 10 лет назад
lease.go 50ad181477 clientv3: support context cancellation on lease keep alives 10 лет назад
op.go 59291770d6 clientv3: WithPrefix operation option 10 лет назад
sort.go 2d2f14385d clientv3: fill in kv ops 10 лет назад
txn.go 7b82576b60 clientv3: copy correct pointers into txn comparisons 10 лет назад
txn_test.go 3c9e8540a7 clientv3: optionize put and delete 10 лет назад
watch.go f66162932c clientv3: fix current watcher reconnection 10 лет назад

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.