dom/telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add integer support to enum processor (#7483)

Browse Source
This commit is contained in:
Harshit Bansal
2020-05-12 00:06:21 +05:30
committed by GitHub
parent 134c84f45d
commit 568cb8e64c
3 changed files with 55 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
plugins/processors/enum/enum.go
View File

@@ -63,7 +63,7 @@ func (mapper *EnumMapper) applyMappings(metric telegraf.Metric) telegraf.Metric
for _, mapping := range mapper.Mappings {
if mapping.Field != "" {
if originalValue, isPresent := metric.GetField(mapping.Field); isPresent {
if adjustedValue, isString := adjustBoolValue(originalValue).(string); isString {
if adjustedValue, isString := adjustValue(originalValue).(string); isString {
if mappedValue, isMappedValuePresent := mapping.mapValue(adjustedValue); isMappedValuePresent {
writeField(metric, mapping.getDestination(), mappedValue)
}
@@ -86,11 +86,17 @@ func (mapper *EnumMapper) applyMappings(metric telegraf.Metric) telegraf.Metric
return metric
}
func adjustBoolValue(in interface{}) interface{} {
if mappedBool, isBool := in.(bool); isBool == true {
return strconv.FormatBool(mappedBool)
func adjustValue(in interface{}) interface{} {
switch val := in.(type) {
case bool:
return strconv.FormatBool(val)
case int64:
return strconv.FormatInt(val, 10)
case uint64:
return strconv.FormatUint(val, 10)
default:
return in
}
return in
}
func (mapping *Mapping) mapValue(original string) (interface{}, bool) {