taskexecutor

Documentation

Index

• type Factory
• type FactoryImpl
  • func (factory *FactoryImpl) GetTaskExecutor(task model.Task) (TaskExecutor, error)
• type KubeJobTaskExecutor
  • func (executor *KubeJobTaskExecutor) Execute(we *model.WorkflowExecution, db *gorm.DB, input string, parentId uint, ...) (*model.TaskExecution, error)
• type ParallelJobTaskExecutor
  • func (executor *ParallelJobTaskExecutor) Execute(we *model.WorkflowExecution, db *gorm.DB, input string, parentId uint, ...) (*model.TaskExecution, error)
• type TaskExecutor

Types

type Factory

type Factory interface {
	GetTaskExecutor(task model.Task) (TaskExecutor, error)
}

type FactoryImpl

type FactoryImpl struct {
	TaskExecutionDao dao.TaskExecutionDao
	KubeClient       kubernetes.Interface
}

func (*FactoryImpl) GetTaskExecutor

func (factory *FactoryImpl) GetTaskExecutor(task model.Task) (TaskExecutor, error)

type KubeJobTaskExecutor

type KubeJobTaskExecutor struct {
	Task             *model.KubeJobTask
	TaskExecutionDao dao.TaskExecutionDao
	KubeClient       kubernetes.Interface
}

func (*KubeJobTaskExecutor) Execute

func (executor *KubeJobTaskExecutor) Execute(we *model.WorkflowExecution, db *gorm.DB, input string, parentId uint, prevId uint) (*model.TaskExecution, error)

type ParallelJobTaskExecutor

type ParallelJobTaskExecutor struct {
	Task                *model.ParallelTask
	TaskExecutionDao    dao.TaskExecutionDao
	TaskExecutorFactory Factory
}

func (*ParallelJobTaskExecutor) Execute

func (executor *ParallelJobTaskExecutor) Execute(we *model.WorkflowExecution, db *gorm.DB, input string, parentId uint, prevId uint) (*model.TaskExecution, error)

type TaskExecutor

type TaskExecutor interface {
	Execute(we *model.WorkflowExecution, db *gorm.DB, input string, parentId uint, prevId uint) (*model.TaskExecution, error)
}