pipelines

Documentation

Index

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

Functions

func Export2CSV

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

func Export2GSHEET

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

func Export2JSON

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

func Export2MONGODB

func Export2MONGODB[IN core.Job, OUT any](_url string, dbName string, collName string) (*export2MONGODB[IN, OUT, core.Output[IN, OUT]], error)

Types

type CloseHook

type CloseHook func()

type OpenHook

type OpenHook func(context.Context) error