diff --git a/engine/storage_mongo_datadb.go b/engine/storage_mongo_datadb.go index cb172108e..dbebe3d50 100644 --- a/engine/storage_mongo_datadb.go +++ b/engine/storage_mongo_datadb.go @@ -24,6 +24,7 @@ import ( "fmt" "io/ioutil" "strings" + "time" "github.com/cgrates/cgrates/cache" "github.com/cgrates/cgrates/config" @@ -112,7 +113,7 @@ func NewMongoStorage(host, port, db, user, pass, storageType string, cdrsIndexes return nil, err } } - ms.cnter = utils.NewCounterGen(0) + ms.cnter = utils.NewCounterGen(time.Now().UnixNano(), 0) return } diff --git a/utils/coreutils.go b/utils/coreutils.go index c8996c748..45ac42777 100644 --- a/utils/coreutils.go +++ b/utils/coreutils.go @@ -40,9 +40,9 @@ import ( "time" ) -func NewCounterGen(limit int64) *CounterGen { +func NewCounterGen(start, limit int64) *CounterGen { return &CounterGen{ - cnt: time.Now().UnixNano(), + cnt: start, limit: limit, } }