dataprocessing

Documentation

Index

• func CheckDataProcessTaskName(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.DataProcessResponse, error)
• func CreateDataProcessTask(_ context.Context, _ client.Client, _ *generated.DataProcessMutation, ...) (*generated.DataProcessResponse, error)
• func DataProcessDetails(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.DataProcessDetails, error)
• func DataProcessLogInfoByFileName(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.DataProcessResponse, error)
• func DataProcessRetry(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.DataProcessResponse, error)
• func DataProcessSupportType(_ context.Context, _ client.Client, _ *generated.DataProcessQuery) (*generated.DataProcessSupportType, error)
• func DeleteDataProcessTask(_ context.Context, _ client.Client, _ *generated.DataProcessMutation, ...) (*generated.DataProcessResponse, error)
• func GetLogInfo(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.DataProcessResponse, error)
• func Init(dataprocessingURL string)
• func ListDataprocessing(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.PaginatedDataProcessItem, error)
• func ListDataprocessingByCount(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, ...) (*generated.CountDataProcessItem, error)

Functions

func CheckDataProcessTaskName

func CheckDataProcessTaskName(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.CheckDataProcessTaskNameInput) (*generated.DataProcessResponse, error)

func CreateDataProcessTask

func CreateDataProcessTask(_ context.Context, _ client.Client, _ *generated.DataProcessMutation, input *generated.AddDataProcessInput) (*generated.DataProcessResponse, error)

func DataProcessDetails

func DataProcessDetails(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.DataProcessDetailsInput) (*generated.DataProcessDetails, error)

func DataProcessLogInfoByFileName

func DataProcessLogInfoByFileName(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.DataProcessFileLogInput) (*generated.DataProcessResponse, error)

func DataProcessRetry

func DataProcessRetry(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.DataProcessRetryInput) (*generated.DataProcessResponse, error)

func DataProcessSupportType

func DataProcessSupportType(_ context.Context, _ client.Client, _ *generated.DataProcessQuery) (*generated.DataProcessSupportType, error)

func DeleteDataProcessTask

func DeleteDataProcessTask(_ context.Context, _ client.Client, _ *generated.DataProcessMutation, input *generated.DeleteDataProcessInput) (*generated.DataProcessResponse, error)

func GetLogInfo

func GetLogInfo(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.DataProcessDetailsInput) (*generated.DataProcessResponse, error)

func Init

func Init(dataprocessingURL string)

func ListDataprocessing

func ListDataprocessing(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.AllDataProcessListByPageInput) (*generated.PaginatedDataProcessItem, error)

func ListDataprocessingByCount

func ListDataprocessingByCount(_ context.Context, _ client.Client, _ *generated.DataProcessQuery, input *generated.AllDataProcessListByCountInput) (*generated.CountDataProcessItem, error)