runner

func CreateAppBasicRes ¶

func CreateAppBasicRes() context.BasicRes

CreateAppBasicRes returns a application level BasicRes instance based on .env/environment variables it is useful because multiple places need BasicRes including `main.go` `directrun` and `worker` keep in mind this function can be called only once

func CreateBasicRes ¶

func CreateBasicRes(cfg config.ConfigReader, logger log.Logger, db *gorm.DB) context.BasicRes

CreateBasicRes returns a BasicRes based on what was given

func DirectRun ¶

func DirectRun(cmd *cobra.Command, args []string, pluginTask plugin.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 GetMigrator ¶

func GetMigrator() plugin.Migrator

GetMigrator returns the shared Migrator singleton

func InitMigrator ¶

func InitMigrator(basicRes context.BasicRes) (plugin.Migrator, errors.Error)

InitMigrator a Migrator singleton

func LoadGoPlugins ¶

func LoadGoPlugins(basicRes context.BasicRes) errors.Error

func LoadPlugins ¶

func LoadPlugins(basicRes context.BasicRes) errors.Error

LoadPlugins load plugins from local directory

func LoadRemotePlugins ¶

func LoadRemotePlugins(basicRes context.BasicRes) errors.Error

func NewGormDb ¶

func NewGormDb(configReader config.ConfigReader, logger log.Logger) (*gorm.DB, errors.Error)

NewGormDb creates a new *gorm.DB and set it up properly

func NewGormDbEx ¶

func NewGormDbEx(configReader config.ConfigReader, logger log.Logger, sessionConfig *dal.SessionConfig) (*gorm.DB, errors.Error)

NewGormDbEx acts like NewGormDb but accept extra sessionConfig

func RunCmd ¶

func RunCmd(cmd *cobra.Command)

RunCmd FIXME ...

func RunPipeline ¶

func RunPipeline(
	basicRes context.BasicRes,
	pipelineId uint64,
	runTasks func([]uint64) errors.Error,
) errors.Error

RunPipeline FIXME ...

func RunPluginSubTasks ¶

func RunPluginSubTasks(
	ctx gocontext.Context,
	basicRes context.BasicRes,
	task *models.Task,
	pluginTask plugin.PluginTask,
	progress chan plugin.RunningProgress,
) errors.Error

RunPluginSubTasks FIXME ...

func RunPluginTask ¶

func RunPluginTask(
	ctx gocontext.Context,
	basicRes context.BasicRes,
	task *models.Task,
	progress chan plugin.RunningProgress,
) errors.Error

RunPluginTask FIXME ...

func RunTask ¶

func RunTask(
	ctx gocontext.Context,
	basicRes context.BasicRes,
	progress chan plugin.RunningProgress,
	taskId uint64,
) (err errors.Error)

RunTask FIXME ...

func UpdateProgressDetail ¶

func UpdateProgressDetail(basicRes context.BasicRes, taskId uint64, progressDetail *models.TaskProgressDetail, p *plugin.RunningProgress)

UpdateProgressDetail FIXME ...