in config.go [154:180]
func GetSourceFromStepConfig(config map[string]interface{}) (Source, error) {
parse := struct {
Source map[string]interface{} `mapstructure:"source"`
}{}
if err := mapstructure.Decode(config, &parse); err != nil {
return nil, err
}
if parse.Source == nil {
return nil, nil
}
if len(parse.Source) == 0 {
return nil, nil
}
stype, err := GetType(parse.Source)
if err != nil {
return nil, err
}
src, err := GetSource(stype, parse.Source)
if err != nil {
return nil, err
}
return src, nil
}