Documentation
¶
Index ¶
- func CreateAppBasicRes() core.BasicRes
- func CreateBasicRes(cfg core.ConfigReader, log core.Logger, db *gorm.DB) core.BasicRes
- func DirectRun(cmd *cobra.Command, args []string, pluginTask core.PluginTask, ...)
- func GetMigrator() core.Migrator
- func InitMigrator(basicRes core.BasicRes) (core.Migrator, errors.Error)
- func LoadPlugins(basicRes core.BasicRes) errors.Error
- func NewGormDb(config core.ConfigReader, logger core.Logger) (*gorm.DB, errors.Error)
- func NewGormDbEx(config core.ConfigReader, logger core.Logger, sessionConfig *dal.SessionConfig) (*gorm.DB, errors.Error)
- func RunCmd(cmd *cobra.Command)
- func RunPipeline(basicRes core.BasicRes, pipelineId uint64, ...) errors.Error
- func RunPluginSubTasks(ctx context.Context, basicRes core.BasicRes, task *models.Task, ...) errors.Error
- func RunPluginTask(ctx context.Context, basicRes core.BasicRes, task *models.Task, ...) errors.Error
- func RunTask(ctx context.Context, basicRes core.BasicRes, ...) (err errors.Error)
- func UpdateProgressDetail(basicRes core.BasicRes, taskId uint64, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAppBasicRes ¶ added in v0.15.0
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 ¶ added in v0.15.0
CreateBasicRes returns a BasicRes based on what was given
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 GetMigrator ¶ added in v0.15.0
GetMigrator returns the shared Migrator singleton
func InitMigrator ¶ added in v0.15.0
InitMigrator a Migrator singleton
func LoadPlugins ¶
LoadPlugins load plugins from local directory
func NewGormDbEx ¶ added in v0.15.0
func NewGormDbEx(config core.ConfigReader, logger core.Logger, sessionConfig *dal.SessionConfig) (*gorm.DB, errors.Error)
NewGormDbEx acts like NewGormDb but accept extra sessionConfig
func RunPipeline ¶
func RunPipeline( basicRes core.BasicRes, pipelineId uint64, runTasks func([]uint64) errors.Error, ) errors.Error
RunPipeline FIXME ...
func RunPluginSubTasks ¶
func RunPluginSubTasks( ctx context.Context, basicRes core.BasicRes, task *models.Task, pluginTask core.PluginTask, progress chan core.RunningProgress, ) errors.Error
RunPluginSubTasks FIXME ...
func RunPluginTask ¶
func RunPluginTask( ctx context.Context, basicRes core.BasicRes, task *models.Task, progress chan core.RunningProgress, ) errors.Error
RunPluginTask FIXME ...
func RunTask ¶
func RunTask( ctx context.Context, basicRes core.BasicRes, progress chan core.RunningProgress, taskId uint64, ) (err errors.Error)
RunTask FIXME ...
func UpdateProgressDetail ¶
func UpdateProgressDetail(basicRes core.BasicRes, taskId uint64, progressDetail *models.TaskProgressDetail, p *core.RunningProgress)
UpdateProgressDetail FIXME ...
Types ¶
This section is empty.
Source Files