in utils/hints.go [90:105]
func GetProcessors(hints mapstr.M, key string) []mapstr.M {
processors := GetConfigs(hints, key, "processors")
for _, proc := range processors {
for key, value := range proc {
if str, ok := value.(string); ok {
cfg := mapstr.M{}
if err := json.Unmarshal([]byte(str), &cfg); err != nil {
logp.NewLogger(logName).Debugw("Unable to unmarshal json due to error", "error", err)
continue
}
proc[key] = cfg
}
}
}
return processors
}