datasource

Documentation

Index

• func ElasticSearchOut(targetSource string, targetSet string, docs []map[string]interface{}, ...)
• 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{}, ...)

Functions

func ElasticSearchOut

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

func GetESClient

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

func GetMysqlClient

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

func QueryForMapSlice

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

func Stdout

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