fix: initialize vbuuid failovermap

Trendyol · Nov 1, 2023 · 9f153c6 · 9f153c6
1 parent 3118a4b
commit 9f153c6
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/couchbase/rollback_mitigation.go b/couchbase/rollback_mitigation.go
@@ -185,9 +185,11 @@ func (r *rollbackMitigation) markAbsentInstances() error { //nolint:unused
 }
 
 func (r *rollbackMitigation) startObserve(groupID int) {
+	r.vbUUIDMap = wrapper.CreateConcurrentSwissMap[uint16, gocbcore.VbUUID](1024)
 
 	r.LoadVbUUIDMap()
 	go r.observeVbUUIDMap()
+
 	r.observeTimer = time.NewTicker(r.config.RollbackMitigation.Interval)
 	for {
 		select {