vm

Documentation

Overview

Package vm provides an abstract test machine (VM, physical machine, etc) interface for the rest of the system. For convenience test machines are subsequently collectively called VMs. Package wraps vmimpl package interface with some common functionality and higher-level interface.

Index

• Variables
• type BootErrorer
• type Instance
  • func (inst *Instance) Close()
  • func (inst *Instance) Copy(hostSrc string) (string, error)
  • func (inst *Instance) Diagnose() bool
  • func (inst *Instance) Forward(port int) (string, error)
  • func (inst *Instance) MonitorExecution(outc <-chan []byte, errc <-chan error, reporter report.Reporter, canExit bool) (rep *report.Report)
  • func (inst *Instance) Run(timeout time.Duration, stop <-chan bool, command string) (outc <-chan []byte, errc <-chan error, err error)
• type Pool
  • func Create(cfg *mgrconfig.Config, debug bool) (*Pool, error)
  • func (pool *Pool) Count() int
  • func (pool *Pool) Create(index int) (*Instance, error)

Variables

var (
	Shutdown   = vmimpl.Shutdown
	ErrTimeout = vmimpl.ErrTimeout
)

Types

type BootErrorer

type BootErrorer interface {
	BootError() (string, []byte)
}

type Instance

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

func (*Instance) Close

func (inst *Instance) Close()

func (*Instance) Copy

func (inst *Instance) Copy(hostSrc string) (string, error)

func (*Instance) Diagnose

func (inst *Instance) Diagnose() bool

func (*Instance) Forward

func (inst *Instance) Forward(port int) (string, error)

func (*Instance) MonitorExecution

func (inst *Instance) MonitorExecution(outc <-chan []byte, errc <-chan error,
	reporter report.Reporter, canExit bool) (rep *report.Report)

MonitorExecution monitors execution of a program running inside of a VM. It detects kernel oopses in output, lost connections, hangs, etc. outc/errc is what vm.Instance.Run returns, reporter parses kernel output for oopses. If canExit is false and the program exits, it is treated as an error. Returns a non-symbolized crash report, or nil if no error happens.

func (*Instance) Run

func (inst *Instance) Run(timeout time.Duration, stop <-chan bool, command string) (
	outc <-chan []byte, errc <-chan error, err error)

type Pool

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

func Create

func Create(cfg *mgrconfig.Config, debug bool) (*Pool, error)

func (*Pool) Count

func (pool *Pool) Count() int

func (*Pool) Create

func (pool *Pool) Create(index int) (*Instance, error)