jobs

package
v0.0.0-...-26736ab Latest Latest
Warning

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

Go to latest
Published: Jan 2, 2019 License: MIT Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetJobWorkingDir

func GetJobWorkingDir(job models.Job) string

GetJobWorkingDir returns the path to a job's working directory

Types

type JobRunner

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

JobRunner is responsible for running jobs.

func NewJobRunner

func NewJobRunner(ctx context.Context, logger golog.Logger,
	etcdKV etcd.KeysAPI) *JobRunner

NewJobRunner creates a new JobRunner

func (*JobRunner) Run

func (r *JobRunner) Run() error

Run starts the JobRunner main logic loop

func (*JobRunner) Submit

func (r *JobRunner) Submit(job *models.Job)

Submit sends a job to the runner main loop for future execution

type PrepareAction

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

PrepareAction downloads a GitHub repository and parses the configuration

func NewPrepareAction

func NewPrepareAction(ctx context.Context, logger golog.Logger,
	etcdKV etcd.KeysAPI) *PrepareAction

NewPrepareAction creates a new PrepareAction

func (*PrepareAction) Run

func (a *PrepareAction) Run(job *models.Job, state *models.ActionState) error

Run executes the prepare action

Jump to

Keyboard shortcuts

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