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) errors.Error
• func NewGormDb(config *viper.Viper, logger core.Logger) (*gorm.DB, errors.Error)
• func RegisterMigrationScripts(scripts []migration.Script, comment string, config core.ConfigGetter, ...)
• func RunCmd(cmd *cobra.Command)
• func RunPipeline(_ *viper.Viper, log core.Logger, db *gorm.DB, pipelineId uint64, ...) errors.Error
• func RunPluginSubTasks(ctx context.Context, cfg *viper.Viper, log core.Logger, db *gorm.DB, ...) errors.Error
• func RunPluginTask(ctx context.Context, cfg *viper.Viper, log core.Logger, db *gorm.DB, ...) errors.Error
• func RunTask(ctx context.Context, _ *viper.Viper, parentLogger core.Logger, db *gorm.DB, ...) (err errors.Error)
• func UpdateProgressDetail(db *gorm.DB, log core.Logger, taskId uint64, ...)

Functions

func DirectRun

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

DirectRun direct run plugin from command line. cmd: type is cobra.Command args: command line arguments pluginTask: specific built-in plugin, for example: feishu, jira... options: plugin config

func LoadPlugins

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

LoadPlugins load plugins from local directory

func NewGormDb

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

NewGormDb FIXME ...

func RegisterMigrationScripts

func RegisterMigrationScripts(scripts []migration.Script, comment string, config core.ConfigGetter, logger core.Logger)

RegisterMigrationScripts FIXME ...

func RunCmd

func RunCmd(cmd *cobra.Command)

RunCmd FIXME ...

func RunPipeline

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

RunPipeline FIXME ...

func RunPluginSubTasks

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

RunPluginSubTasks FIXME ...

func RunPluginTask

func RunPluginTask(
	ctx context.Context,
	cfg *viper.Viper,
	log core.Logger,
	db *gorm.DB,
	taskID uint64,
	name string,
	subtasks []string,
	options map[string]interface{},
	progress chan core.RunningProgress,
) errors.Error

RunPluginTask FIXME ...

func RunTask

func RunTask(
	ctx context.Context,
	_ *viper.Viper,
	parentLogger core.Logger,
	db *gorm.DB,
	progress chan core.RunningProgress,
	taskId uint64,
) (err errors.Error)

RunTask FIXME ...

func UpdateProgressDetail

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

UpdateProgressDetail FIXME ...