taskexecutor

package
v0.0.0-...-0de2bea Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2019 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL