@@ -222,7 +222,7 @@ var queryOverrides = map[string]string{
222
222
}
223
223
224
224
// Add queries to the metricMaps and queryOverrides maps
225
- func add_queries (queriesPath string ) (err error ) {
225
+ func addQueries (queriesPath string ) (err error ) {
226
226
var extra map [string ]interface {}
227
227
228
228
content , err := ioutil .ReadFile (queriesPath )
@@ -258,7 +258,7 @@ func add_queries(queriesPath string) (err error) {
258
258
for attr_key , attr_val := range a .(map [interface {}]interface {}) {
259
259
switch (attr_key .(string )) {
260
260
case "usage" :
261
- usage , err := _string_to_columnusage (attr_val .(string ))
261
+ usage , err := stringToColumnUsage (attr_val .(string ))
262
262
if err != nil {
263
263
return err
264
264
}
@@ -282,34 +282,6 @@ func add_queries(queriesPath string) (err error) {
282
282
return
283
283
}
284
284
285
- // convert a string to the corresponding ColumnUsage
286
- func _string_to_columnusage (s string ) (u ColumnUsage , err error ) {
287
- switch (s ) {
288
- case "DISCARD" :
289
- u = DISCARD
290
-
291
- case "LABEL" :
292
- u = LABEL
293
-
294
- case "COUNTER" :
295
- u = COUNTER
296
-
297
- case "GAUGE" :
298
- u = GAUGE
299
-
300
- case "MAPPEDMETRIC" :
301
- u = MAPPEDMETRIC
302
-
303
- case "DURATION" :
304
- u = DURATION
305
- default :
306
- err = fmt .Errorf ("wrong ColumnUsage given : %s" , s )
307
- }
308
-
309
- return
310
- }
311
-
312
-
313
285
// Turn the MetricMap column mapping into a prometheus descriptor mapping.
314
286
func makeDescMap (metricMaps map [string ]map [string ]ColumnMapping ) map [string ]MetricMapNamespace {
315
287
var metricMap = make (map [string ]MetricMapNamespace )
@@ -400,6 +372,34 @@ func makeDescMap(metricMaps map[string]map[string]ColumnMapping) map[string]Metr
400
372
return metricMap
401
373
}
402
374
375
+ // convert a string to the corresponding ColumnUsage
376
+ func stringToColumnUsage (s string ) (u ColumnUsage , err error ) {
377
+ switch (s ) {
378
+ case "DISCARD" :
379
+ u = DISCARD
380
+
381
+ case "LABEL" :
382
+ u = LABEL
383
+
384
+ case "COUNTER" :
385
+ u = COUNTER
386
+
387
+ case "GAUGE" :
388
+ u = GAUGE
389
+
390
+ case "MAPPEDMETRIC" :
391
+ u = MAPPEDMETRIC
392
+
393
+ case "DURATION" :
394
+ u = DURATION
395
+
396
+ default :
397
+ err = fmt .Errorf ("wrong ColumnUsage given : %s" , s )
398
+ }
399
+
400
+ return
401
+ }
402
+
403
403
// Convert database.sql types to float64s for Prometheus consumption. Null types are mapped to NaN. string and []byte
404
404
// types are mapped as NaN and !ok
405
405
func dbToFloat64 (t interface {}) (float64 , bool ) {
@@ -672,7 +672,7 @@ func main() {
672
672
}
673
673
674
674
if * queriesPath != "" {
675
- err := add_queries (* queriesPath )
675
+ err := addQueries (* queriesPath )
676
676
if err != nil {
677
677
log .Warnln ("Unparseable queries file - discarding merge: " , * queriesPath , err )
678
678
}
0 commit comments