jobrunner

Documentation

Index

• type JobRunner
  • func New(workerQueue chan chan *models.Job, apiClient *apiclient.APIClient, ...) *JobRunner
  • func (jobRunner *JobRunner) Shutdown()
  • func (jobRunner *JobRunner) Start()

Types

type JobRunner

type JobRunner struct {
	// contains filtered or unexported fields
}

JobRunner loops indefinitely and runs one job at a time

func New

func New(workerQueue chan chan *models.Job, apiClient *apiclient.APIClient, workingDirectory string, logger log.Logger) *JobRunner

New creates a new JobRunner

func (*JobRunner) Shutdown

func (jobRunner *JobRunner) Shutdown()

Shutdown stops the JobRunner gracefully, interrupting all running jobs but requeueing them on the master node.

func (*JobRunner) Start

func (jobRunner *JobRunner) Start()

Start executing jobs