taskpoller

Documentation

Index

• type Factory
• type FactoryImpl
  • func (factory *FactoryImpl) GetTaskPoller(te *model.TaskExecution, jobDef *model.JobDef) (TaskPoller, error)
• type KubeJobTaskPoller
  • func (poller *KubeJobTaskPoller) Poll(te *model.TaskExecution, db *gorm.DB) (bool, error)
• type ParallelJobTaskPoller
  • func (poller *ParallelJobTaskPoller) Poll(te *model.TaskExecution, db *gorm.DB) (bool, error)
• type TaskPoller

Types

type Factory

type Factory interface {
	GetTaskPoller(*model.TaskExecution, *model.JobDef) (TaskPoller, error)
}

type FactoryImpl

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

func (*FactoryImpl) GetTaskPoller

func (factory *FactoryImpl) GetTaskPoller(te *model.TaskExecution, jobDef *model.JobDef) (TaskPoller, error)

type KubeJobTaskPoller

type KubeJobTaskPoller struct {
	Client           kubernetes.Interface
	TaskExecutionDao dao.TaskExecutionDao
}

func (*KubeJobTaskPoller) Poll

func (poller *KubeJobTaskPoller) Poll(te *model.TaskExecution, db *gorm.DB) (bool, error)

type ParallelJobTaskPoller

type ParallelJobTaskPoller struct {
	TaskExecutionDao dao.TaskExecutionDao
	TaskDef          *model.ParallelTask
}

func (*ParallelJobTaskPoller) Poll

func (poller *ParallelJobTaskPoller) Poll(te *model.TaskExecution, db *gorm.DB) (bool, error)

type TaskPoller

type TaskPoller interface {
	// Check if TaskExecution completed
	Poll(*model.TaskExecution, *gorm.DB) (bool, error)
}