uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-24 08:38:45 +05:00
Code Issues Packages Projects Releases Wiki Activity

Update migrator to use InternalDB

Browse Source
This commit is contained in:
TeoV
2019-10-02 08:54:21 -04:00
committed by Dan Christian Bogos
parent e95127d84a
commit f9d8ac49f8
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
migrator/accounts2_it_test.go
View File

@@ -121,10 +121,10 @@ func testAcc2ITFlush(t *testing.T) {
if acc2Migrator.dmOut.DataManager().DataDB().GetStorageType() != utils.REDIS {
t.Errorf("Unexpected datadb type : %+v", acc2Migrator.dmOut.DataManager().DataDB().GetStorageType())
}
if acc2Migrator.storDBIn.StorDB().GetStorageType() != utils.MAPSTOR {
if acc2Migrator.storDBIn.StorDB().GetStorageType() != utils.INTERNAL {
t.Errorf("Unexpected datadb type : %+v", acc2Migrator.storDBIn.StorDB().GetStorageType())
}
if acc2Migrator.storDBOut.StorDB().GetStorageType() != utils.MAPSTOR {
if acc2Migrator.storDBOut.StorDB().GetStorageType() != utils.INTERNAL {
t.Errorf("Unexpected datadb type : %+v", acc2Migrator.storDBOut.StorDB().GetStorageType())
}
}

4
migrator/storage_map_stordb.go
View File

@@ -26,13 +26,13 @@ import (
func newMapStorDBMigrator(stor engine.StorDB) (mpMig *mapStorDBMigrator) {
return &mapStorDBMigrator{
storDB: &stor,
mp: stor.(*engine.MapStorage),
iDB: stor.(*engine.InternalDB),
}
}
type mapStorDBMigrator struct {
storDB *engine.StorDB
mp *engine.MapStorage
iDB *engine.InternalDB
dataKeys []string
qryIdx *int
}