From 187903e3c3a60ecc9eefc480da48012af718ab2b Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Thu, 18 Jul 2024 18:10:54 +0800
Subject: [PATCH] version log index

---
 pkg/common/storage/database/mgo/version_log.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/common/storage/database/mgo/version_log.go b/pkg/common/storage/database/mgo/version_log.go
index 80b5658c6..3b449007b 100644
--- a/pkg/common/storage/database/mgo/version_log.go
+++ b/pkg/common/storage/database/mgo/version_log.go
@@ -18,8 +18,8 @@ import (
 
 func NewVersionLog(coll *mongo.Collection) (database.VersionLog, error) {
 	lm := &VersionLogMgo{coll: coll}
-	if lm.initIndex(context.Background()) != nil {
-		return nil, errs.ErrInternalServer.WrapMsg("init index failed", "coll", coll.Name())
+	if err := lm.initIndex(context.Background()); err != nil {
+		return nil, errs.WrapMsg(err, "init version log index failed", "coll", coll.Name())
 	}
 	return lm, nil
 }
@@ -33,6 +33,7 @@ func (l *VersionLogMgo) initIndex(ctx context.Context) error {
 		Keys: bson.M{
 			"d_id": 1,
 		},
+		Options: options.Index().SetUnique(true),
 	})
 	return err
 }