framework

Mar 5, 2019

Changes in this version

+ const BusyboxImage

type DockerContainerExecInterface

+ func (*DockerContainerExecInterface) Logs() (string, error)

type Executor

+ Logs func() (string, error)

+ type HostPathMount struct

+ ContainerPath string

+ HostPath string

type LocalCmd

+ func (l *LocalCmd) Logs() (string, error)

+ type RunPodOptions struct

+ Command []string

+ ExposePorts []int32

+ HostPathMounts []HostPathMount

+ NodeName string

+ Timeout time.Duration

type VMOptions

+ SystemUUID string

Nov 15, 2018

Changes in this version

type VMOptions

+ InjectFilesToRootfsFrom string

Sep 19, 2018

Changes in this version

+ const NginxImage

+ type PVCInterface struct

+ Claim *v1.PersistentVolumeClaim

+ Spec PVCSpec

+ Volume *v1.PersistentVolume

+ func (pvci *PVCInterface) AddToPod(pi *PodInterface, name string)

+ func (pvci *PVCInterface) Create() error

+ func (pvci *PVCInterface) Delete() error

+ func (pvci *PVCInterface) WaitForDestruction(timing ...time.Duration) error

+ type PVCSpec struct

+ Block bool

+ CephMonitorIP string

+ CephRBDImage string

+ CephRBDPool string

+ CephSecretName string

+ ContainerPath string

+ FlexVolumeOptions map[string]string

+ LocalPath string

+ Name string

+ NodeName string

+ Size string

type PodInterface

+ func (pi *PodInterface) LoadEvents() ([]string, error)

+ func (pi *PodInterface) WaitForDestruction(timing ...time.Duration) error

+ func (pi *PodInterface) WaitForPodStatus(expectedContainerErrors []string, timing ...time.Duration) error

type VMInterface

+ PVCs []*PVCInterface

+ func (vmi *VMInterface) CreateAndWait(options VMOptions, waitTimeout time.Duration, beforeCreate func(*PodInterface)) error

+ func (vmi *VMInterface) PodWithoutChecks() *PodInterface

type VMOptions

+ PVCs []PVCSpec

Aug 27, 2018

Changes in this version

type VMOptions

+ RootVolumeSize string

Jul 11, 2018

Changes in this version

type Controller

+ func (c *Controller) AddLabelsToNode(nodeName string, labels map[string]string) error

+ func (c *Controller) AvailableNodeName() (string, error)

+ func (c *Controller) CreateVirtletConfigMapping(configMapping virtlet_v1.VirtletConfigMapping) (*virtlet_v1.VirtletConfigMapping, error)

+ func (c *Controller) DeleteVirtletConfigMapping(name string) error

+ func (c *Controller) RemoveLabelOffNode(nodeName string, labelKeys []string) error

+ func (c *Controller) WaitForVirtletPodOnTheNode(name string) (*PodInterface, error)

+ func (c *Controller) WaitForVirtletPodToDisappearFromTheNode(name string) error

type VMOptions

+ MultiCNI string

Apr 4, 2018

Changes in this version

+ var ClusterURL = flag.String("cluster-url", "http://127.0.0.1:8080", "apiserver URL")

+ func Run(executor Executor, input string, command ...string) (string, string, error)

+ func RunSimple(executor Executor, command ...string) (string, error)

+ type Command interface

+ Kill func() error

+ Wait func() error

+ type CommandError struct

+ ExitCode int

+ func (e CommandError) Error() string

type DockerContainerExecInterface

+ func (*DockerContainerExecInterface) Start(stdin io.Reader, stdout, stderr io.Writer, command ...string) (Command, error)

+ func (n *DockerContainerExecInterface) Run(stdin io.Reader, stdout, stderr io.Writer, command ...string) error

type Executor

+ Run func(stdin io.Reader, stdout, stderr io.Writer, command ...string) error

+ Start func(stdin io.Reader, stdout, stderr io.Writer, command ...string) (Command, error)

type LocalCmd

+ func (l *LocalCmd) Run(stdin io.Reader, stdout, stderr io.Writer, command ...string) error

+ func (l *LocalCmd) Start(stdin io.Reader, stdout, stderr io.Writer, command ...string) (Command, error)

type PodInterface

+ func (pi *PodInterface) PortForward(ports []*tools.ForwardedPort) (chan struct{}, error)

Oct 30, 2017

Changes in this version

+ var ErrTimeout = fmt.Errorf("timeout")

+ func Curl(url string) (string, error)

+ func Exec(executor Executor, command []string, input string) (string, string, int, error)

+ func ExecSimple(executor Executor, command ...string) (string, error)

+ func RunVirsh(virtletPod *PodInterface, command ...string) (string, error)

+ func WithTimeout(timeout time.Duration, fn func() error) func() error

+ type Controller struct

+ func NewController(namespace string) (*Controller, error)

+ func (c *Controller) ConfigMaps() typedv1.ConfigMapInterface

+ func (c *Controller) CreateVirtletImageMapping(mapping imagetranslation.VirtletImageMapping) (*imagetranslation.VirtletImageMapping, error)

+ func (c *Controller) DeleteVirtletImageMapping(name string) error

+ func (c *Controller) DinDNodeExecutor(name string) (Executor, error)

+ func (c *Controller) DockerContainer(name string) (*DockerContainerInterface, error)

+ func (c *Controller) Finalize() error

+ func (c *Controller) FindPod(namespace string, labelMap map[string]string, ...) (*PodInterface, error)

+ func (c *Controller) Namespace() string

+ func (c *Controller) PersistentVolumeClaimsClient() typedv1.PersistentVolumeClaimInterface

+ func (c *Controller) PersistentVolumesClient() typedv1.PersistentVolumeInterface

+ func (c *Controller) Pod(name, namespace string) (*PodInterface, error)

+ func (c *Controller) RunPod(name, image string, command []string, timeout time.Duration, ...) (*PodInterface, error)

+ func (c *Controller) Secrets() typedv1.SecretInterface

+ func (c *Controller) VM(name string) *VMInterface

+ func (c *Controller) VirtletNodeName() (string, error)

+ func (c *Controller) VirtletPod() (*PodInterface, error)

+ type DockerContainerExecInterface struct

+ func (*DockerContainerExecInterface) Close() error

+ func (n *DockerContainerExecInterface) Exec(command []string, stdin io.Reader, stdout, stderr io.Writer) (int, error)

+ type DockerContainerInterface struct

+ ID string

+ Name string

+ func (d *DockerContainerInterface) Container() (*types.Container, error)

+ func (d *DockerContainerInterface) Delete() error

+ func (d *DockerContainerInterface) Executor(privileged bool, user string) Executor

+ func (d *DockerContainerInterface) PullImage(name string) error

+ func (d *DockerContainerInterface) Run(image string, env map[string]string, network string, ports []string, ...) error

+ type Executor interface

+ Exec func(command []string, stdin io.Reader, stdout, stderr io.Writer) (int, error)

+ type LocalCmd struct

+ func LocalExecutor(ctx context.Context) *LocalCmd

+ func (l *LocalCmd) Close() error

+ func (l *LocalCmd) Exec(command []string, stdin io.Reader, stdout, stderr io.Writer) (int, error)

+ type PodInterface struct

+ Pod *v1.Pod

+ func (pi *PodInterface) Container(name string) (Executor, error)

+ func (pi *PodInterface) Create() error

+ func (pi *PodInterface) Delete() error

+ func (pi *PodInterface) DinDNodeExecutor() (Executor, error)

+ func (pi *PodInterface) Wait(timing ...time.Duration) error

+ func (pi *PodInterface) WaitDestruction(timing ...time.Duration) error

+ type VMInterface struct

+ Name string

+ func (vmi *VMInterface) Create(options VMOptions, waitTimeout time.Duration, beforeCreate func(*PodInterface)) error

+ func (vmi *VMInterface) Delete(waitTimeout time.Duration) error

+ func (vmi *VMInterface) Domain() (libvirtxml.Domain, error)

+ func (vmi *VMInterface) DomainName() (string, error)

+ func (vmi *VMInterface) Pod() (*PodInterface, error)

+ func (vmi *VMInterface) SSH(user, secret string) (Executor, error)

+ func (vmi *VMInterface) VirshCommand(command ...string) (string, error)

+ func (vmi *VMInterface) VirtletPod() (*PodInterface, error)

+ type VMOptions struct

+ CloudInitScript string

+ DiskDriver string

+ Image string

+ Limits map[string]string

+ NodeName string

+ OverwriteUserData bool

+ SSHKey string

+ SSHKeySource string

+ UserData string

+ UserDataScript string

+ UserDataSource string

+ VCPUCount int