in packages/datastream.go [420:446]
func findField(allFields []util.MapStr, searchedName string) (*fieldEntry, error) {
for _, fields := range allFields {
name, err := fields.GetValue("name")
if err != nil {
return nil, fmt.Errorf("cannot get value (key: name): %w", err)
}
if name != searchedName {
continue
}
aType, err := fields.GetValue("type")
if err != nil {
return nil, fmt.Errorf("cannot get value (key: type): %w", err)
}
if aType == "" {
return nil, fmt.Errorf("field '%s' found, but type is undefined", searchedName)
}
return &fieldEntry{
name: name.(string),
aType: aType.(string),
}, nil
}
return nil, fmt.Errorf("field '%s' not found", searchedName)
}