mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
clientv3/integration: fix typos
Signed-off-by: Gyuho Lee <gyuhox@gmail.com>
This commit is contained in:
parent
a609b1eb47
commit
bf83d5269f
@ -54,7 +54,7 @@ func TestBalancerUnderBlackholeKeepAliveWatch(t *testing.T) {
|
|||||||
// TODO: only send healthy endpoint to gRPC so gRPC wont waste time to
|
// TODO: only send healthy endpoint to gRPC so gRPC wont waste time to
|
||||||
// dial for unhealthy endpoint.
|
// dial for unhealthy endpoint.
|
||||||
// then we can reduce 3s to 1s.
|
// then we can reduce 3s to 1s.
|
||||||
timeout := pingInterval + intergration.RequestWaitTimeout
|
timeout := pingInterval + integration.RequestWaitTimeout
|
||||||
|
|
||||||
cli, err := clientv3.New(ccfg)
|
cli, err := clientv3.New(ccfg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -121,7 +121,7 @@ func testDialSetEndpoints(t *testing.T, setBefore bool) {
|
|||||||
if !setBefore {
|
if !setBefore {
|
||||||
cli.SetEndpoints(eps[toKill%3], eps[(toKill+1)%3])
|
cli.SetEndpoints(eps[toKill%3], eps[(toKill+1)%3])
|
||||||
}
|
}
|
||||||
ctx, cancel := context.WithTimeout(context.Background(), intergration.RequestWaitTimeout)
|
ctx, cancel := context.WithTimeout(context.Background(), integration.RequestWaitTimeout)
|
||||||
if _, err = cli.Get(ctx, "foo", clientv3.WithSerializable()); err != nil {
|
if _, err = cli.Get(ctx, "foo", clientv3.WithSerializable()); err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user