runner

Documentation

Index

• func DirectRun(cmd *cobra.Command, args []string, pluginTask core.PluginTask, ...)
• func LoadPlugins(pluginsDir string, config *viper.Viper, logger core.Logger, db *gorm.DB) error
• func MigrateDb(db *gorm.DB) error
• func NewGormDb(config *viper.Viper, logger core.Logger) (*gorm.DB, error)
• func RunCmd(cmd *cobra.Command)
• func RunPipeline(cfg *viper.Viper, log core.Logger, db *gorm.DB, pipelineId uint64, ...) error
• func RunPluginSubTasks(cfg *viper.Viper, logger core.Logger, db *gorm.DB, ctx context.Context, ...) error
• func RunPluginTask(cfg *viper.Viper, logger core.Logger, db *gorm.DB, ctx context.Context, ...) error
• func RunTask(cfg *viper.Viper, logger core.Logger, db *gorm.DB, ctx context.Context, ...) error
• func UpdateProgressDetail(db *gorm.DB, taskId uint64, progressDetail *models.TaskProgressDetail, ...)

Functions

func DirectRun

func DirectRun(cmd *cobra.Command, args []string, pluginTask core.PluginTask, options map[string]interface{})

func LoadPlugins

func LoadPlugins(pluginsDir string, config *viper.Viper, logger core.Logger, db *gorm.DB) error

LoadPlugins load plugins from local directory

func MigrateDb

func MigrateDb(db *gorm.DB) error

func NewGormDb

func NewGormDb(config *viper.Viper, logger core.Logger) (*gorm.DB, error)

func RunCmd

func RunCmd(cmd *cobra.Command)

func RunPipeline

func RunPipeline(
	cfg *viper.Viper,
	log core.Logger,
	db *gorm.DB,
	pipelineId uint64,
	runTasks func([]uint64) error,
) error

func RunPluginSubTasks

func RunPluginSubTasks(
	cfg *viper.Viper,
	logger core.Logger,
	db *gorm.DB,
	ctx context.Context,
	name string,
	options map[string]interface{},
	pluginTask core.PluginTask,
	progress chan core.RunningProgress,
) error

func RunPluginTask

func RunPluginTask(
	cfg *viper.Viper,
	logger core.Logger,
	db *gorm.DB,
	ctx context.Context,
	name string,
	options map[string]interface{},
	progress chan core.RunningProgress,
) error

func RunTask

func RunTask(
	cfg *viper.Viper,
	logger core.Logger,
	db *gorm.DB,
	ctx context.Context,
	progress chan core.RunningProgress,
	taskId uint64,
) error

func UpdateProgressDetail

func UpdateProgressDetail(db *gorm.DB, taskId uint64, progressDetail *models.TaskProgressDetail, p *core.RunningProgress)