Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CollectResults ¶ added in v0.1.2
func CollectResults() []interface{}
///////////////////////////////////////////////////////// COLLECT RECORDS Append messages from resultChan to slice until resultChan is closed /////////////////////////////////////////////////////////
func GatherRecords ¶ added in v0.1.2
func GatherRecords(f sourceFunction) ([]interface{}, error)
///////////////////////////////////////////////////////// GATHER Gather processed records /////////////////////////////////////////////////////////
func ParseCSV ¶
func ParseCSV()
///////////////////////////////////////////////////////// PARSE /////////////////////////////////////////////////////////
func ParseDB ¶
func ParseDB()
///////////////////////////////////////////////////////// PARSE /////////////////////////////////////////////////////////
func ParseJSONL ¶
func ParseJSONL()
///////////////////////////////////////////////////////// PARSE /////////////////////////////////////////////////////////
Types ¶
This section is empty.
Source Files