Catch log of embedded etcd in tests (follow-up to #718).

This commit is contained in:
Joachim Bauch 2024-04-25 16:07:51 +02:00
parent 2d48018b58
commit 9e2a896326
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02

View file

@ -38,6 +38,8 @@ import (
clientv3 "go.etcd.io/etcd/client/v3"
"go.etcd.io/etcd/server/v3/embed"
"go.etcd.io/etcd/server/v3/lease"
"go.uber.org/zap"
"go.uber.org/zap/zaptest"
)
var (
@ -88,6 +90,7 @@ func NewEtcdForTest(t *testing.T) *embed.Etcd {
cfg.ListenPeerUrls = []url.URL{*peerListener}
cfg.AdvertisePeerUrls = []url.URL{*peerListener}
cfg.InitialCluster = "default=" + peerListener.String()
cfg.ZapLoggerBuilder = embed.NewZapLoggerBuilder(zaptest.NewLogger(t, zaptest.Level(zap.WarnLevel)))
etcd, err = embed.StartEtcd(cfg)
if isErrorAddressAlreadyInUse(err) {
continue