Rename from *opensips_flatstore and *kamailio_flatstore to *flatsore

This commit is contained in:
TeoV
2020-01-22 14:10:07 +02:00
parent f307639646
commit 85ffef5028
8 changed files with 8 additions and 14 deletions

View File

@@ -299,7 +299,7 @@ var posibleLoaderTypes = utils.NewStringSet([]string{utils.MetaAttributes,
var possibleReaderTypes = utils.NewStringSet([]string{utils.MetaFileCSV,
utils.MetaKafkajsonMap, utils.MetaFileXML, utils.MetaSQL, utils.MetaFileFWV,
utils.MetaPartialCSV, utils.MetaOsipsFlatstore, utils.MetaKamFlatstore})
utils.MetaPartialCSV, utils.MetaFlatstore})
func (cfg *CGRConfig) LazySanityCheck() {
for _, cdrePrfl := range cfg.cdrsCfg.OnlineCDRExports {

View File

@@ -399,7 +399,7 @@ func (cfg *CGRConfig) checkConfigSanity() error {
}
switch rdr.Type {
case utils.MetaFileCSV, utils.MetaPartialCSV, utils.MetaOsipsFlatstore, utils.MetaKamFlatstore:
case utils.MetaFileCSV, utils.MetaPartialCSV, utils.MetaFlatstore:
for _, dir := range []string{rdr.ProcessedPath, rdr.SourcePath} {
if _, err := os.Stat(dir); err != nil && os.IsNotExist(err) {
return fmt.Errorf("<%s> Nonexistent folder: %s for reader with ID: %s", utils.ERs, dir, rdr.ID)

View File

@@ -329,7 +329,7 @@
"id": "FlatstoreOsips",
"enabled": true,
"run_delay": -1,
"type": "*opensips_flatstore",
"type": "*flatstore",
"field_separator": "|",
"source_path": "/tmp/flatstoreErs/in",
"processed_path": "/tmp/flatstoreErs/out",

View File

@@ -332,7 +332,7 @@
"id": "FlatstoreOsips",
"enabled": true,
"run_delay": -1,
"type": "*opensips_flatstore",
"type": "*flatstore",
"field_separator": "|",
"source_path": "/tmp/flatstoreErs/in",
"processed_path": "/tmp/flatstoreErs/out",

View File

@@ -329,7 +329,7 @@
"id": "FlatstoreOsips",
"enabled": true,
"run_delay": -1,
"type": "*opensips_flatstore",
"type": "*flatstore",
"field_separator": "|",
"source_path": "/tmp/flatstoreErs/in",
"processed_path": "/tmp/flatstoreErs/out",

View File

@@ -326,7 +326,7 @@
"id": "FlatstoreOsips",
"enabled": true,
"run_delay": -1,
"type": "*opensips_flatstore",
"type": "*flatstore",
"field_separator": "|",
"source_path": "/tmp/flatstoreErs/in",
"processed_path": "/tmp/flatstoreErs/out",

View File

@@ -50,7 +50,7 @@ func NewEventReader(cfg *config.CGRConfig, cfgIdx int,
return NewKafkaER(cfg, cfgIdx, rdrEvents, rdrErr, fltrS, rdrExit)
case utils.MetaSQL:
return NewSQLEventReader(cfg, cfgIdx, rdrEvents, rdrErr, fltrS, rdrExit)
case utils.MetaKamFlatstore, utils.MetaOsipsFlatstore:
case utils.MetaFlatstore:
return NewFlatstoreER(cfg, cfgIdx, rdrEvents, rdrErr, fltrS, rdrExit)
}
return

View File

@@ -25,8 +25,6 @@ var (
MainCDRFields = NewStringSet([]string{CGRID, Source, OriginHost, OriginID, ToR, RequestType, Tenant, Category,
Account, Subject, Destination, SetupTime, AnswerTime, Usage, COST, RATED, Partial, RunID,
PreRated, CostSource, CostDetails, ExtraInfo, OrderID})
CDRCFileFormats = NewStringSet([]string{MetaFileCSV, MetaFScsv,
MetaKamFlatstore, MetaOsipsFlatstore, MetaPartialCSV, MetaFileFWV, MetaFileXML})
PostPaidRatedSlice = []string{META_POSTPAID, META_RATED}
ItemList = NewStringSet([]string{MetaAccounts, MetaAttributes, MetaChargers, MetaDispatchers, MetaDispatcherHosts,
MetaFilters, MetaResources, MetaStats, MetaThresholds, MetaSuppliers,
@@ -258,9 +256,7 @@ const (
ThresholdPrefix = "thd_"
TimingsPrefix = "tmg_"
FilterPrefix = "ftr_"
FilterIndex = "fti_"
CDR_STATS_PREFIX = "cst_"
LOG_CALL_COST_PREFIX = "cco_"
VERSION_PREFIX = "ver_"
StatQueueProfilePrefix = "sqp_"
SupplierProfilePrefix = "spp_"
@@ -281,7 +277,6 @@ const (
META_HTTP_POST = "*http_post"
MetaHTTPjson = "*http_json"
MetaHTTPjsonCDR = "*http_json_cdr"
META_HTTP_JSONRPC = "*http_jsonrpc"
MetaHTTPjsonMap = "*http_json_map"
MetaAMQPjsonCDR = "*amqp_json_cdr"
MetaAMQPjsonMap = "*amqp_json_map"
@@ -292,8 +287,7 @@ const (
MetaS3jsonMap = "*s3_json_map"
CONFIG_PATH = "/etc/cgrates/"
DISCONNECT_CAUSE = "DisconnectCause"
MetaKamFlatstore = "*kamailio_flatstore"
MetaOsipsFlatstore = "*opensips_flatstore"
MetaFlatstore = "*flatstore"
MetaRating = "*rating"
NOT_AVAILABLE = "N/A"
CALL = "call"