Finished renaming opts for Event Exporter

This commit is contained in:
andronache
2021-05-10 12:34:03 +03:00
committed by Dan Christian Bogos
parent a7245520a7
commit ccf014451c
6 changed files with 15 additions and 16 deletions

View File

@@ -456,19 +456,19 @@ const CGRATES_CFG_JSON = `
// "sqlMaxConnLifetime": 0, // SQLMaxConnLifetime
// "sqlTableName":"cdrs", // the name of the table from where the events are exported
// "dbName": "cgrates", // the name of the database from where the events are exported
// "sqlTableName":"cdrs", // the name of the table from where the events are exported
// "sqlDBName": "cgrates", // the name of the database from where the events are exported
// "sslmode": "disable", // the postgresSSLMode for postgres
// Kafka
// "topic": "cgrates", // the topic from where the events are exported
// "kafkaTopic": "cgrates", // the topic from where the events are exported
// AMQP
// "routingKey": "", // RoutingKey
// "exchange": "", // Exchange
// "exchangeType": "", // ExchangeType
// "amqpRoutingKey": "", // RoutingKey
// "sqlExchange": "", // Exchange
// "sqlExchangeType": "", // ExchangeType
// SQS and S3

View File

@@ -356,16 +356,16 @@
// // AMQP
// // "consumerTag": "cgrates", // the ID of the consumer
// // "exchange": "",
// // "exchangeType": "",
// // "routingKey": "",
// // "sqlExchange": "",
// // "sqlExchangeType": "",
// // "amqpRoutingKey": "",
// // "exchangeProcessed": "",
// // "exchangeTypeProcessed": "",
// // "routingKeyProcessed": "",
// // Kafka
// // "topic": "cgrates", // the topic from were the events are read
// // "kafkaTopic": "cgrates", // the topic from were the events are read
// // "groupID": "cgrates", // the group that reads the events
// // "maxWait": "1ms", // the maximum amount of time to wait for new data to come
@@ -373,11 +373,11 @@
// // SQL
// // "dbName": "cgrates", // the name of the database from were the events are read
// // "sqlDBName": "cgrates", // the name of the database from were the events are read
// // "sqlTableName": "cdrs", // the name of the table from were the events are read
// // "sslMode": "disable", // the ssl mode for postgres db
// // "dbNameProcessed": "", // the name of the database were the events are sent after they are processed
// // "sqlDBNameProcessed": "", // the name of the database were the events are sent after they are processed
// // "sqlTableNameProcessed": "", // the name of the table were the events are sent after they are processed
// // "sslModeProcessed": "", // the ssl mode for postgres db

View File

@@ -394,7 +394,7 @@
"export_path": "mysql://cgrates:CGRateS.org@127.0.0.1:3306",
"attempts": 1,
"opts": {
"dbName": "exportedDatabase", // if dbName is not present "cgrates" will be used as default
"sqlDBName": "exportedDatabase", // if dbName is not present "cgrates" will be used as default
"sqlTableName": "expTable", // tableName is mandatory in opts for sql exporter
"sslMode": "disable",
"sqlMaxIdleConns": "10",

View File

@@ -327,7 +327,6 @@ func (rdr *SQLEventReader) setURL(inURL, outURL string, opts map[string]interfac
rdr.expTableName = utils.CDRsTBL
if vals, has := processedOpt[utils.SQLTableNameOpt]; has {
rdr.expTableName = utils.IfaceAsString(vals)
}
switch rdr.expConnType {