taskrunner

Documentation

Index

• Constants
• type AgentHostGateway
  • func (agbh *AgentHostGateway) GetAgentRevision() (string, error)
  • func (agbh *AgentHostGateway) StartAgentOnHost(settings *evergreen.Settings, hostObj host.Host) error
• type HostGateway
• type Runner
  • func (r *Runner) Description() string
  • func (r *Runner) Name() string
  • func (r *Runner) Run(config *evergreen.Settings) error
• type TaskRunner
  • func NewTaskRunner(settings *evergreen.Settings) *TaskRunner
  • func (tr *TaskRunner) Run() error

Constants

const (
	MakeShellTimeout  = 2 * time.Minute
	SCPTimeout        = 3 * time.Minute
	StartAgentTimeout = 2 * time.Minute
)

const (
	RunnerName  = "taskrunner"
	Description = "dispatch agents to free hosts"
)

Types

type AgentHostGateway

type AgentHostGateway struct {
	// Destination directory for the agent executables
	ExecutablesDir string
}

Implementation of the HostGateway that builds and copies over the MCI agent to run tasks.

func (*AgentHostGateway) GetAgentRevision

func (agbh *AgentHostGateway) GetAgentRevision() (string, error)

Gets the git revision of the currently built agent

func (*AgentHostGateway) StartAgentOnHost

func (agbh *AgentHostGateway) StartAgentOnHost(settings *evergreen.Settings, hostObj host.Host) error

Start the task specified, on the host specified. First runs any necessary preparation on the remote machine, then kicks off the agent process on the machine. Returns an error if any step along the way fails.

type HostGateway

type HostGateway interface {
	// run the specified task on the specified host, return the revision of the
	// agent running the task on that host
	StartAgentOnHost(*evergreen.Settings, host.Host) error
	// gets the current revision of the agent
	GetAgentRevision() (string, error)
}

HostGateway is responsible for kicking off tasks on remote machines.

type Runner

type Runner struct{}

func (*Runner) Description

func (r *Runner) Description() string

func (*Runner) Name

func (r *Runner) Name() string

func (*Runner) Run

func (r *Runner) Run(config *evergreen.Settings) error

type TaskRunner

type TaskRunner struct {
	*evergreen.Settings
	HostGateway
}

TODO: take out task queue finder and host finder once transition is complete

func NewTaskRunner

func NewTaskRunner(settings *evergreen.Settings) *TaskRunner

func (*TaskRunner) Run

func (tr *TaskRunner) Run() error