pipelines

Documentation

Index

• func Export2CSV[IN core.Job, OUT any](args ...string) *export2CSV[IN, OUT, core.Output[IN, OUT]]
• func Export2GSHEET[IN core.Job, OUT any](keyFilePath, spreadSheetId string, sheetId int64) *export2GSHEET[IN, OUT, core.Output[IN, OUT]]
• func Export2JSON[IN core.Job, OUT any](args ...string) *export2JSON[IN, OUT, core.Output[IN, OUT]]
• type CloseHook
• type OpenHook

Functions

func Export2CSV

func Export2CSV[IN core.Job, OUT any](args ...string) *export2CSV[IN, OUT, core.Output[IN, OUT]]

func Export2GSHEET

func Export2GSHEET[IN core.Job, OUT any](keyFilePath, spreadSheetId string, sheetId int64) *export2GSHEET[IN, OUT, core.Output[IN, OUT]]

func Export2JSON

func Export2JSON[IN core.Job, OUT any](args ...string) *export2JSON[IN, OUT, core.Output[IN, OUT]]

Types

type CloseHook

type CloseHook func()

type OpenHook

type OpenHook func(context.Context) error