feat: panic when snapshot marker order corrupted

Trendyol · Jan 25, 2025 · 22dfa56 · 22dfa56
1 parent 3bbd4e7
commit 22dfa56
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/couchbase/observer.go b/couchbase/observer.go
@@ -2,6 +2,7 @@ package couchbase
 
 import (
 	"context"
+	"fmt"
 	"reflect"
 	"time"
 
@@ -185,7 +186,9 @@ func (so *observer) IsInSnapshotMarker(seqNo uint64) bool {
 		seqNo >= so.currentSnapshot.StartSeqNo && seqNo <= so.currentSnapshot.EndSeqNo
 
 	if !isIn {
-		logger.Log.Warn("seqNo not in snapshot: %v", seqNo)
+		err := fmt.Errorf("seqNo not in snapshot: %v, vbID: %v", seqNo, so.vbID)
+		logger.Log.Error("error while snapshot marker check, err: %v", err)
+		panic(err)
 	}
 
 	return isIn