jobs

Documentation

Index

• func GetJobWorkingDir(job models.Job) string
• type JobRunner
  • func NewJobRunner(ctx context.Context, logger golog.Logger, etcdKV etcd.KeysAPI) *JobRunner
  • func (r *JobRunner) Run() error
  • func (r *JobRunner) Submit(job *models.Job)
• type PrepareAction
  • func NewPrepareAction(ctx context.Context, logger golog.Logger, etcdKV etcd.KeysAPI) *PrepareAction
  • func (a *PrepareAction) Run(job *models.Job, state *models.ActionState) error

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