sync etcd endpoints immediately after initializing the client (#1573)

vldmit · web-flow · commit 279dcd5b29a2 · 2025-02-17T04:12:30.000Z
Signed-off-by: Vlad Dmitriev &lt;vldmit@gmail.com&gt;
diff --git a/tikv/kv.go b/tikv/kv.go
@@ -103,6 +103,12 @@ func createEtcdKV(addrs []string, tlsConfig *tls.Config) (*clientv3.Client, erro
 	if err != nil {
 		return nil, errors.WithStack(err)
 	}
+	ctx, cancel := context.WithTimeout(context.TODO(), 5*time.Second)
+	defer cancel()
+	if err := cli.Sync(ctx); err != nil {
+		_ = cli.Close()
+		return nil, errors.WithStack(err)
+	}
 	return cli, nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -103,6 +103,12 @@ func createEtcdKV(addrs []string, tlsConfig tls.Config) (clientv3.Client, erro`
`103`	`103`	`if err != nil {`
`104`	`104`	`return nil, errors.WithStack(err)`
`105`	`105`	`}`
	`106`	`+ ctx, cancel := context.WithTimeout(context.TODO(), 5*time.Second)`
	`107`	`+ defer cancel()`
	`108`	`+ if err := cli.Sync(ctx); err != nil {`
	`109`	`+ _ = cli.Close()`
	`110`	`+ return nil, errors.WithStack(err)`
	`111`	`+ }`
`106`	`112`	`return cli, nil`
`107`	`113`	`}`
`108`	`114`