job

Documentation

Index

• func ReadCache(job types.ZadigJobTask, dest, cacheDir string, logger *zap.SugaredLogger)
• func WriteCache(job types.ZadigJobTask, src string, cachePath string, ...)
• type JobExecutor
  • func NewJobExecutor(ctx context.Context, job *types.ZadigJobTask, client *network.ZadigClient, ...) *JobExecutor
  • func (e *JobExecutor) AfterExecute() error
  • func (e *JobExecutor) BeforeExecute() error
  • func (e *JobExecutor) CheckZadigCancel() bool
  • func (e *JobExecutor) Execute()
  • func (e *JobExecutor) InitWorkDirectory() error
  • func (e *JobExecutor) StopJob() error

Functions

func ReadCache

func ReadCache(job types.ZadigJobTask, dest, cacheDir string, logger *zap.SugaredLogger)

func WriteCache

func WriteCache(job types.ZadigJobTask, src string, cachePath string, logger *zap.SugaredLogger)

Types

type JobExecutor

type JobExecutor struct {
	Ctx              context.Context
	Wg               *sync.WaitGroup
	Cmd              *common.Command
	Job              *types.ZadigJobTask
	JobCtx           *jobctl.JobContext
	Client           *network.ZadigClient
	Logger           *log.JobLogger
	Writer           *io.Writer
	Reporter         *reporter.JobReporter
	DockerHost       string
	JobResult        *types.JobExecuteResult
	OutputsJsonBytes []byte
	Cancel           *bool
	FinishedChan     chan struct{}
	ReporterCancel   context.CancelFunc
	Dirs             *types.AgentWorkDirs
}

func NewJobExecutor

func NewJobExecutor(ctx context.Context, job *types.ZadigJobTask, client *network.ZadigClient, reporterCancel context.CancelFunc) *JobExecutor

func (*JobExecutor) AfterExecute

func (e *JobExecutor) AfterExecute() error

func (*JobExecutor) BeforeExecute

func (e *JobExecutor) BeforeExecute() error

BeforeExecute init execute context and command

func (*JobExecutor) CheckZadigCancel

func (e *JobExecutor) CheckZadigCancel() bool

func (*JobExecutor) Execute

func (e *JobExecutor) Execute()

func (*JobExecutor) InitWorkDirectory

func (e *JobExecutor) InitWorkDirectory() error

func (*JobExecutor) StopJob

func (e *JobExecutor) StopJob() error