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

implement batched index retrieval in GetIndexes method

Browse Source
This commit is contained in:
ionutboangiu
2025-09-12 06:36:24 +03:00
committed by Dan Christian Bogos
parent 8d05c14aec
commit 8546c4c64e
16 changed files with 112 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
migrator/alias_it_test.go
View File

@@ -228,7 +228,7 @@ func testAlsITMigrateAndMove(t *testing.T) {
}
if alsidx, err := alsMigrator.dmOut.DataManager().GetIndexes(
utils.CacheAttributeFilterIndexes, utils.ConcatenatedKey("cgrates.org", utils.MetaAny),
"", false, false); err != nil {
false, false); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expAlsIdx, alsidx) {
t.Errorf("Expected %v, received: %v", utils.ToJSON(expAlsIdx), utils.ToJSON(alsidx))

4
migrator/derived_chargers_it_test.go
View File

@@ -243,7 +243,7 @@ func testDCITMigrateAndMove(t *testing.T) {
if dcidx, err := dcMigrator.dmOut.DataManager().GetIndexes(
utils.CacheAttributeFilterIndexes,
utils.ConcatenatedKey("cgrates.org", utils.MetaChargers),
"", true, true); err != nil {
true, true); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expDcIdx, dcidx) {
t.Errorf("Expected %v, received: %v", utils.ToJSON(expDcIdx), utils.ToJSON(dcidx))
@@ -256,7 +256,7 @@ func testDCITMigrateAndMove(t *testing.T) {
if dcidx, err := dcMigrator.dmOut.DataManager().GetIndexes(
utils.CacheChargerFilterIndexes,
utils.ConcatenatedKey("cgrates.org", utils.MetaChargers),
"", true, true); err == nil || err.Error() != utils.ErrNotFound.Error() {
true, true); err == nil || err.Error() != utils.ErrNotFound.Error() {
t.Errorf("Expected error %v, received: %v with reply: %v", utils.ErrNotFound, err, utils.ToJSON(dcidx))
} else if dcMigrator.stats[utils.DerivedChargersV] != 1 {
t.Errorf("Expected 1, received: %v", dcMigrator.stats[utils.DerivedChargersV])

4
migrator/filters_it_test.go
View File

@@ -272,7 +272,7 @@ func testFltrITMigrateAndMove(t *testing.T) {
if fltridx, err := fltrMigrator.dmOut.DataManager().GetIndexes(
utils.CacheAttributeFilterIndexes,
utils.ConcatenatedKey(attrProf.Tenant, utils.MetaAny),
"", false, false); err != nil {
false, false); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expFltrIdx, fltridx) {
t.Errorf("Expected %v, received: %v", utils.ToJSON(expFltrIdx), utils.ToJSON(fltridx))
@@ -470,7 +470,7 @@ func testFltrITMigratev2(t *testing.T) {
if fltridx, err := fltrMigrator.dmOut.DataManager().GetIndexes(
utils.CacheAttributeFilterIndexes,
utils.ConcatenatedKey(attrProf.Tenant, utils.MetaAny),
"", false, true); err != nil {
false, true); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expFltrIdx, fltridx) {
t.Errorf("Expected %v, received: %v", utils.ToJSON(expFltrIdx), utils.ToJSON(fltridx))

2
migrator/user_it_test.go
View File

@@ -202,7 +202,7 @@ func testUsrITMigrateAndMove(t *testing.T) {
if usridx, err := usrMigrator.dmOut.DataManager().GetIndexes(
utils.CacheAttributeFilterIndexes,
utils.ConcatenatedKey("cgrates.org", utils.MetaAny),
"", true, true); err != nil {
true, true); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(expUsrIdx, usridx) {
t.Errorf("Expected %v, received: %v", utils.ToJSON(expUsrIdx), utils.ToJSON(usridx))