manager

Documentation

Overview

Package manager provides Dryad Job Manager.

Index

• Variables
• func NewDryadJobManager(artifactDBPath string) weles.DryadJobManager
• type DryadJobRunner
• type DryadJobs
  • func (d *DryadJobs) Cancel(job weles.JobID) error
  • func (d *DryadJobs) Create(job weles.JobID, rusalka weles.Dryad, conf weles.Config, ...) error
  • func (d *DryadJobs) List(filter *weles.DryadJobFilter) ([]weles.DryadJobInfo, error)

Variables

var (
	// ErrDuplicated is returned when a creation of dryadJob with known JobID has been requested.
	ErrDuplicated = errors.New("job with given ID already exists")
	// ErrNotExist is returned when an argument did not match any known dryadJob.
	ErrNotExist = errors.New("job with given ID does not exist")
)

Functions

func NewDryadJobManager

func NewDryadJobManager(artifactDBPath string) weles.DryadJobManager

NewDryadJobManager returns DryadJobManager interface of a new instance of DryadJobs.

Types

type DryadJobRunner

type DryadJobRunner interface {
	// Deploy prepares device for Boot.
	//
	// It usually formats SDcard and copies image to it.
	Deploy() error

	// Boot starts up a device and prepares environment for Test.
	//
	// It usually attempts to log in to console.
	Boot() error

	// Test runs tests on a device.
	//
	// Test usually consists of following actions:
	// Push - deploy additional content,
	// Execute - run requested commands,
	// Collect - gather results.
	Test() error
}

DryadJobRunner executes DryadJob on allocated Dryad. SessionProvider is used for actions on Dryad, DeviceCommunicationProvider - device.

type DryadJobs

type DryadJobs struct {
	weles.DryadJobManager
	// contains filtered or unexported fields
}

DryadJobs implements DryadJobManager interface.

func (*DryadJobs) Cancel

func (d *DryadJobs) Cancel(job weles.JobID) error

Cancel is part of DryadJobManager interface.

func (*DryadJobs) Create

func (d *DryadJobs) Create(job weles.JobID, rusalka weles.Dryad, conf weles.Config,
	changes chan<- weles.DryadJobStatusChange) error

Create is part of DryadJobManager interface.

func (*DryadJobs) List

func (d *DryadJobs) List(filter *weles.DryadJobFilter) ([]weles.DryadJobInfo, error)

List is part of DryadJobManager interface.