From 1093683b4761160682abbcf55b80b9da29ada1a1 Mon Sep 17 00:00:00 2001
From: Andras Banki-Horvath <bhandras@gmail.com>
Date: Fri, 21 Jan 2022 17:24:55 +0100
Subject: [PATCH] etcd: set embedded etcd default max msg size and up txn limit

---
 kvdb/etcd/embed.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/kvdb/etcd/embed.go b/kvdb/etcd/embed.go
index 0df2f804f..107fca1d3 100644
--- a/kvdb/etcd/embed.go
+++ b/kvdb/etcd/embed.go
@@ -68,7 +68,7 @@ func NewEmbeddedEtcdInstance(path string, clientPort, peerPort uint16,
 	cfg.Dir = path
 
 	// To ensure that we can submit large transactions.
-	cfg.MaxTxnOps = 8192
+	cfg.MaxTxnOps = 16384
 	cfg.MaxRequestBytes = 16384 * 1024
 	cfg.Logger = "zap"
 	if logFile != "" {
@@ -109,6 +109,7 @@ func NewEmbeddedEtcdInstance(path string, clientPort, peerPort uint16,
 		Host:               "http://" + clientURL,
 		InsecureSkipVerify: true,
 		Namespace:          defaultNamespace,
+		MaxMsgSize:         int(cfg.MaxRequestBytes),
 	}
 
 	return connConfig, func() {