func GetSourceFromStepConfig()

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
}