in plugins/plugins.go [82:102]
func LogKey(record map[interface{}]interface{}, logKey string) (*interface{}, error) {
for key, val := range record {
var currentKey string
switch t := key.(type) {
case []byte:
currentKey = string(t)
case string:
currentKey = t
default:
logrus.Debugf("[go plugin]: Unable to determine type of key %v\n", t)
continue
}
if logKey == currentKey {
return &val, nil
}
}
return nil, fmt.Errorf("Failed to find key %s specified by log_key option in log record: %v", logKey, record)
}