Documentation ¶
Index ¶
- func DiskCallbackFactory(output string, writeImages bool, writeTimeseries bool, wg *sync.WaitGroup) (common.Callback, common.CallbackTeardown)
- func GetJSONFilename(templateName string) string
- func ParquetCallbackFactory(output string, wg *sync.WaitGroup) (common.Callback, common.CallbackTeardown)
- func StdoutCallbackFactory(out io.Writer, writeTimeseries bool) (common.Callback, common.CallbackTeardown)
- func WriteJSON(target io.Writer, pkg *common.DataRecord, jsonFileName string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DiskCallbackFactory ¶
func DiskCallbackFactory( output string, writeImages bool, writeTimeseries bool, wg *sync.WaitGroup, ) (common.Callback, common.CallbackTeardown)
DiskCallbackFactory returns a callback for disk writes
func GetJSONFilename ¶ added in v0.2.0
GetJSONFilename replaces extension in template name with .json
func ParquetCallbackFactory ¶ added in v1.0.0
func ParquetCallbackFactory( output string, wg *sync.WaitGroup, ) (common.Callback, common.CallbackTeardown)
DiskCallbackFactory returns a callback for disk writes
func StdoutCallbackFactory ¶
func StdoutCallbackFactory( out io.Writer, writeTimeseries bool, ) (common.Callback, common.CallbackTeardown)
StdoutCallbackFactory returns a callback that writes to stdout
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.