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

Add TTL option for DataDB/StorDB for type *internal

Browse Source
This commit is contained in:
TeoV
2020-01-14 08:41:49 -05:00
parent 434cd8bb47
commit 35d19ab4b2
46 changed files with 568 additions and 395 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/cgr-loader/cgr-loader.go
View File

@@ -252,7 +252,7 @@ func main() {
ldrCfg.DataDbCfg().DataDbHost, ldrCfg.DataDbCfg().DataDbPort,
ldrCfg.DataDbCfg().DataDbName, ldrCfg.DataDbCfg().DataDbUser,
ldrCfg.DataDbCfg().DataDbPass, ldrCfg.GeneralCfg().DBDataEncoding,
ldrCfg.DataDbCfg().DataDbSentinelName)
ldrCfg.DataDbCfg().DataDbSentinelName, ldrCfg.DataDbCfg().Items)
if err != nil {
log.Fatalf("Coud not open dataDB connection: %s", err.Error())
}
@@ -267,7 +267,7 @@ func main() {
ldrCfg.StorDbCfg().Password, ldrCfg.StorDbCfg().SSLMode,
ldrCfg.StorDbCfg().MaxOpenConns, ldrCfg.StorDbCfg().MaxIdleConns,
ldrCfg.StorDbCfg().ConnMaxLifetime, ldrCfg.StorDbCfg().StringIndexedFields,
ldrCfg.StorDbCfg().PrefixIndexedFields); err != nil {
ldrCfg.StorDbCfg().PrefixIndexedFields, ldrCfg.StorDbCfg().Items); err != nil {
log.Fatalf("Coud not open storDB connection: %s", err.Error())
}
defer storDb.Close()

8
cmd/cgr-migrator/cgr-migrator.go
View File

@@ -230,7 +230,7 @@ func main() {
mgrCfg.DataDbCfg().DataDbHost, mgrCfg.DataDbCfg().DataDbPort,
mgrCfg.DataDbCfg().DataDbName, mgrCfg.DataDbCfg().DataDbUser,
mgrCfg.DataDbCfg().DataDbPass, mgrCfg.GeneralCfg().DBDataEncoding,
mgrCfg.CacheCfg(), mgrCfg.DataDbCfg().DataDbSentinelName); err != nil {
mgrCfg.CacheCfg(), mgrCfg.DataDbCfg().DataDbSentinelName, mgrCfg.DataDbCfg().Items); err != nil {
log.Fatal(err)
}
@@ -240,7 +240,7 @@ func main() {
mgrCfg.MigratorCgrCfg().OutDataDBHost, mgrCfg.MigratorCgrCfg().OutDataDBPort,
mgrCfg.MigratorCgrCfg().OutDataDBName, mgrCfg.MigratorCgrCfg().OutDataDBUser,
mgrCfg.MigratorCgrCfg().OutDataDBPassword, mgrCfg.MigratorCgrCfg().OutDataDBEncoding,
mgrCfg.CacheCfg(), mgrCfg.MigratorCgrCfg().OutDataDBRedisSentinel); err != nil {
mgrCfg.CacheCfg(), mgrCfg.MigratorCgrCfg().OutDataDBRedisSentinel, mgrCfg.DataDbCfg().Items); err != nil {
log.Fatal(err)
}
@@ -319,7 +319,7 @@ func main() {
mgrCfg.StorDbCfg().Password, mgrCfg.StorDbCfg().SSLMode,
mgrCfg.StorDbCfg().MaxOpenConns, mgrCfg.StorDbCfg().MaxIdleConns,
mgrCfg.StorDbCfg().ConnMaxLifetime, mgrCfg.StorDbCfg().StringIndexedFields,
mgrCfg.StorDbCfg().PrefixIndexedFields); err != nil {
mgrCfg.StorDbCfg().PrefixIndexedFields, mgrCfg.StorDbCfg().Items); err != nil {
log.Fatal(err)
}
@@ -331,7 +331,7 @@ func main() {
mgrCfg.MigratorCgrCfg().OutStorDBPassword, mgrCfg.StorDbCfg().SSLMode,
mgrCfg.StorDbCfg().MaxOpenConns, mgrCfg.StorDbCfg().MaxIdleConns,
mgrCfg.StorDbCfg().ConnMaxLifetime, mgrCfg.StorDbCfg().StringIndexedFields,
mgrCfg.StorDbCfg().PrefixIndexedFields); err != nil {
mgrCfg.StorDbCfg().PrefixIndexedFields, mgrCfg.StorDbCfg().Items); err != nil {
log.Fatal(err)
}

2
cmd/cgr-tester/cgr-tester.go
View File

@@ -76,7 +76,7 @@ func durInternalRater(cd *engine.CallDescriptorWithArgDispatcher) (time.Duration
tstCfg.DataDbCfg().DataDbHost, tstCfg.DataDbCfg().DataDbPort,
tstCfg.DataDbCfg().DataDbName, tstCfg.DataDbCfg().DataDbUser,
tstCfg.DataDbCfg().DataDbPass, tstCfg.GeneralCfg().DBDataEncoding,
tstCfg.DataDbCfg().DataDbSentinelName)
tstCfg.DataDbCfg().DataDbSentinelName, tstCfg.DataDbCfg().Items)
if err != nil {
return nilDuration, fmt.Errorf("Could not connect to data database: %s", err.Error())
}