Anthony Romano 4fb25d5f0e Merge pull request #4613 from heyitsanthony/clientv3-composite 9 năm trước cách đây
..
concurrency f8c3fa637f clientv3: use default client lease api 9 năm trước cách đây
integration d02b1c982f clientv3: return closed channel on Watch() cancel 9 năm trước cách đây
mirror 3e57bbf317 clientv3: use default client kv 9 năm trước cách đây
README.md 72a1e5618b clientv3: add more code examples 9 năm trước cách đây
client.go 5f62c05a6d clientv3: compose all clientv3 APIs into client struct 9 năm trước cách đây
client_test.go 71c2a9bb3c *: fix minor typos, comments 10 năm trước cách đây
cluster.go b19d57e1c3 clientv3: fix godoc for member apis 10 năm trước cách đây
compare.go 4f41d361a8 clientv3: make compare compliant with proposed txn usage 10 năm trước cách đây
doc.go 72a1e5618b clientv3: add more code examples 9 năm trước cách đây
example_cluster_test.go 8f7d474a6b clientv3: use default client cluster 9 năm trước cách đây
example_kv_test.go 3e57bbf317 clientv3: use default client kv 9 năm trước cách đây
example_lease_test.go f8c3fa637f clientv3: use default client lease api 9 năm trước cách đây
example_test.go 3e57bbf317 clientv3: use default client kv 9 năm trước cách đây
example_watch_test.go d430c7baf7 clientv3: use default client watcher 9 năm trước cách đây
kv.go 43689b9a32 clientv3: expose Do in KV 9 năm trước cách đây
lease.go 993fd76b19 clientv3: respect first stream error in lease recv loop 9 năm trước cách đây
op.go d4b2044eb1 clientv3/concurrency: Mutex 9 năm trước cách đây
sort.go 2d2f14385d clientv3: fill in kv ops 10 năm trước cách đây
txn.go 7b82576b60 clientv3: copy correct pointers into txn comparisons 9 năm trước cách đây
txn_test.go 3c9e8540a7 clientv3: optionize put and delete 10 năm trước cách đây
watch.go d02b1c982f clientv3: return closed channel on Watch() cancel 9 năm trước cách đây

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.