datasource

func ElasticSearchOut(targetSource string, targetSet string, docs []map[string]interface{}, idColumn string)

func GetESClient(name string) (*elasticsearch.Client, error)

func GetMysqlClient(name string) (*sql.DB, error)

func QueryForMapSlice(db *sql.DB, query string) []map[string]string

func Stdout(targetSource string, targetSet string, docs []map[string]interface{}, idColumn string)