platform

Aug 1, 2019

Changes in this version

+ var ErrBothSizeAndFile = errors.New("Only one of Size and BackingFile can be specified")

+ var ErrNeedSizeOrFile = errors.New("Disks need either Size or BackingFile specified")

+ func CreateQEMUCommand(board, uuid, biosImage, consolePath, confPath, diskImagePath string, ...) ([]string, []*os.File, error)

+ func GenerateFakeKey() (string, error)

+ func MakeCLDiskTemplate(inputPath string) (output *os.File, result error)

+ func Virtio(board, device, args string) string

type BaseCluster

+ func (bc *BaseCluster) IgnitionVersion() string

type Cluster

+ IgnitionVersion func() string

+ type Disk struct

+ BackingFile string

+ DeviceOpts []string

+ Size string

+ type MachineOptions struct

+ AdditionalDisks []Disk

type Options

+ IgnitionVersion string

+ OSContainer string

Mar 6, 2019

Changes in this version

type BaseCluster

+ func (bc *BaseCluster) Distribution() string

+ func (bc *BaseCluster) JournalOutput() map[string]string

+ type BaseFlight struct

+ func NewBaseFlight(opts *Options, platform Name, ctPlatform string) (*BaseFlight, error)

+ func NewBaseFlightWithDialer(opts *Options, platform Name, ctPlatform string, dialer network.Dialer) (*BaseFlight, error)

+ func (bf *BaseFlight) AddCluster(c Cluster)

+ func (bf *BaseFlight) Clusters() []Cluster

+ func (bf *BaseFlight) DelCluster(c Cluster)

+ func (bf *BaseFlight) Destroy()

+ func (bf *BaseFlight) Keys() ([]*agent.Key, error)

+ func (bf *BaseFlight) Name() string

+ func (bf *BaseFlight) Platform() Name

type Cluster

+ JournalOutput func() map[string]string

+ Name func() string

+ type Flight interface

+ Clusters func() []Cluster

+ Destroy func()

+ Name func() string

+ NewCluster func(rconf *RuntimeConfig) (Cluster, error)

+ Platform func() Name

type Machine

+ JournalOutput func() string

type Options

+ Distribution string

Jun 11, 2018

Changes in this version

type Journal

+ func (j *Journal) Read() ([]byte, error)

Apr 17, 2018

Changes in this version

type Options

+ SystemdDropins []SystemdDropin

+ type SystemdDropin struct

+ Contents string

+ Name string

+ Unit string

Feb 13, 2018

Changes in this version

type BaseCluster

+ func (bc *BaseCluster) Platform() Name

type Cluster

+ Platform func() Name

type Machine

+ RuntimeConf func() RuntimeConfig

+ type Name string

type RuntimeConfig

+ AllowFailedUnits bool

Aug 24, 2017

Changes in this version

+ func RebootMachine(m Machine, j *Journal, c RuntimeConfig) error

+ func StartMachine(m Machine, j *Journal, c RuntimeConfig) error

type RuntimeConfig

+ NoEnableSelinux bool

Jun 21, 2017

Changes in this version

type BaseCluster

+ func (bc *BaseCluster) ConsoleOutput() map[string]string

+ func (bc *BaseCluster) RenderUserData(userdata *conf.UserData, ignitionVars map[string]string) (*conf.Conf, error)

+ func (bc *BaseCluster) RuntimeConf() RuntimeConfig

+ func (bc *BaseCluster) UserSSHClient(ip, user string) (*ssh.Client, error)

type Cluster

+ ConsoleOutput func() map[string]string

type Machine

+ ConsoleOutput func() string

+ type RuntimeConfig struct

+ NoSSHKeyInMetadata bool

+ NoSSHKeyInUserData bool

+ OutputDir string

Mar 1, 2017

Changes in this version

+ func StartReboot(m Machine) error

type BaseCluster

+ func (bc *BaseCluster) OutputDir() string

+ type Journal struct

+ func NewJournal(dir string) (*Journal, error)

+ func (j *Journal) Destroy() error

+ func (j *Journal) Start(ctx context.Context, m Machine) error

type Machine

+ Reboot func() error

Sep 16, 2016

Changes in this version

+ func CheckMachine(m Machine) error

+ func EnableSelinux(m Machine) error

+ type BaseCluster struct

+ func NewBaseCluster(basename string) (*BaseCluster, error)

+ func NewBaseClusterWithDialer(basename string, dialer network.Dialer) (*BaseCluster, error)

+ func (bc *BaseCluster) AddMach(m Machine)

+ func (bc *BaseCluster) DelMach(m Machine)

+ func (bc *BaseCluster) Destroy() error

+ func (bc *BaseCluster) GetDiscoveryURL(size int) (string, error)

+ func (bc *BaseCluster) Keys() ([]*agent.Key, error)

+ func (bc *BaseCluster) Machines() []Machine

+ func (bc *BaseCluster) Name() string

+ func (bc *BaseCluster) PasswordSSHClient(ip string, user string, password string) (*ssh.Client, error)

+ func (bc *BaseCluster) SSH(m Machine, cmd string) ([]byte, error)

+ func (bc *BaseCluster) SSHClient(ip string) (*ssh.Client, error)

May 18, 2016

Changes in this version

type TestCluster

+ func (t *TestCluster) Error(e error)

+ func (t *TestCluster) Errorf(format string, args ...interface{})

+ func (t *TestCluster) Skip(args ...interface{})

+ func (t *TestCluster) Skipf(format string, args ...interface{})

May 16, 2016

Changes in this version

type Machine

+ PasswordSSHClient func(user string, password string) (*ssh.Client, error)

+ type Options struct

+ BaseName string

type QEMUCluster

+ func (bc QEMUCluster) PasswordSSHClient(ip string, user string, password string) (*ssh.Client, error)

Apr 22, 2016

Changes in this version

type QEMUOptions

+ BIOSImage string

+ Board string

Feb 17, 2016

Changes in this version

+ func ReadFile(m Machine, path string) (io.ReadCloser, error)

+ func TransferFile(src Machine, srcPath string, dst Machine, dstPath string) error

Feb 2, 2016

Changes in this version

+ func GCECreateImage(api *compute.Service, proj, name, source string) error

+ func GCECreateVM(api *compute.Service, opts *GCEOptions, userdata string) (*gceMachine, error)

+ func GCEDestroyVM(api *compute.Service, proj, zone, name string) error

+ func GCEForceCreateImage(api *compute.Service, proj, name, source string) error

+ func GCEListImages(client *http.Client, proj, prefix string) ([]string, error)

+ func InstallFile(in io.Reader, m Machine, to string) error

+ func Manhole(m Machine) error

+ func Reboot(m Machine) error

+ func StreamJournal(m Machine) error

+ type AWSOptions struct

+ AMI string

+ InstanceType string

+ KeyName string

+ SecurityGroup string

+ type Cluster interface

+ Destroy func() error

+ GetDiscoveryURL func(size int) (string, error)

+ Machines func() []Machine

+ NewMachine func(config string) (Machine, error)

+ func NewAWSCluster(conf AWSOptions) (Cluster, error)

+ func NewGCECluster(conf GCEOptions) (Cluster, error)

+ func NewQemuCluster(conf QEMUOptions) (Cluster, error)

+ type Conf struct

+ func NewConf(userdata string) (*Conf, error)

+ func (c *Conf) CopyKeys(keys []*agent.Key)

+ func (c *Conf) String() string

+ type GCEOptions struct

+ BaseName string

+ DiskType string

+ Image string

+ MachineType string

+ Network string

+ Project string

+ ServiceAuth bool

+ Zone string

+ type Machine interface

+ Destroy func() error

+ ID func() string

+ IP func() string

+ PrivateIP func() string

+ SSH func(cmd string) ([]byte, error)

+ SSHClient func() (*ssh.Client, error)

+ func GCEListVMs(api *compute.Service, opts *GCEOptions, prefix string) ([]Machine, error)

+ func NewMachines(c Cluster, userdatas []string) ([]Machine, error)

+ type QEMUCluster struct

+ func (bc QEMUCluster) Machines() []Machine

+ func (bc QEMUCluster) SSH(m Machine, cmd string) ([]byte, error)

+ func (bc QEMUCluster) SSHClient(ip string) (*ssh.Client, error)

+ func (qc *QEMUCluster) Destroy() error

+ func (qc *QEMUCluster) GetDiscoveryURL(size int) (string, error)

+ func (qc *QEMUCluster) NewMachine(cfg string) (Machine, error)

+ type QEMUOptions struct

+ DiskImage string

+ type TestCluster struct

+ Name string

+ NativeFuncs []string

+ Options map[string]string

+ func (t *TestCluster) DropFile(localPath string) error

+ func (t *TestCluster) ListNativeFunctions() []string

+ func (t *TestCluster) RunNative(funcName string, m Machine) error