sync etcd endpoints immediately after initializing the client

Signed-off-by: Vlad Dmitriev <[email protected]>
tikv · Feb 13, 2025 · 46b1b9e · 46b1b9e
1 parent ec9ad0f
commit 46b1b9e
Showing 1 changed file with 6 additions and 0 deletions.
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
 }