e2e_node

README

PLEASE NOTE: This document applies to the HEAD of the source tree

If you are using a released version of Kubernetes, you should refer to the docs that go with that version.

The latest release of this document can be found [here](http://releases.k8s.io/release-1.1/docs/devel/collab.md).

Documentation for other releases can be found at releases.k8s.io.

See e2e-node-tests

Documentation

Overview

e2e_node contains e2e tests specific to the node TODO: rename this package e2e-node

Index

• Constants
• Variables
• func AddHostnameIp(hostname, ip string)
• func CreateTestArchive() (string, error)
• func GetHostnameOrIp(hostname string) string
• func NewDefaultFramework(baseName string) *framework.Framework
• func PrePullAllImages() error
• func RunRemote(archive string, host string, cleanup bool, junitFileNumber int, setupNode bool) (string, bool, error)
• func RunSshCommand(cmd string, args ...string) (string, error)
• type ConformanceContainer
  • func (cc *ConformanceContainer) Create()
  • func (cc *ConformanceContainer) Delete() error
  • func (cc *ConformanceContainer) GetPhase() (api.PodPhase, error)
  • func (cc *ConformanceContainer) GetStatus() (api.ContainerStatus, error)
  • func (cc *ConformanceContainer) IsReady() (bool, error)
  • func (cc *ConformanceContainer) Present() (bool, error)
• type ConformanceImage
  • func NewConformanceImage(containerRuntime string, image string) (ci ConformanceImage, err error)
  • func (ci *ConformanceImage) GetTag() string
  • func (ci *ConformanceImage) List() ([]string, error)
  • func (ci *ConformanceImage) Present() (bool, error)
  • func (ci *ConformanceImage) Pull() error
  • func (ci *ConformanceImage) Remove() error
• type ContainerState
  • func GetContainerState(state api.ContainerState) ContainerState

Constants

const (
	CNIRelease   = "c864f0e1ea73719b8f4582402b0847064f9883b0"
	CNIDirectory = "cni"
)

const (
	// This is consistent with the level used in a cluster e2e test.
	LOG_VERBOSITY_LEVEL = "4"
)

Variables

var CNIURL = fmt.Sprintf("https://storage.googleapis.com/kubernetes-release/network-plugins/cni-%s.tar.gz", CNIRelease)

var ImageRegistry = map[int]string{
	// contains filtered or unexported fields
}

var NoPullImageRegistry = map[int]string{
	// contains filtered or unexported fields
}

These are used by tests that explicitly test the ability to pull images

Functions

func AddHostnameIp

func AddHostnameIp(hostname, ip string)

func CreateTestArchive

func CreateTestArchive() (string, error)

CreateTestArchive builds the local source and creates a tar archive e2e_node_test.tar.gz containing the binaries k8s required for node e2e tests

func GetHostnameOrIp

func GetHostnameOrIp(hostname string) string

func NewDefaultFramework

func NewDefaultFramework(baseName string) *framework.Framework

func PrePullAllImages

func PrePullAllImages() error

Pre-fetch all images tests depend on so that we don't fail in an actual test

func RunRemote

func RunRemote(archive string, host string, cleanup bool, junitFileNumber int, setupNode bool) (string, bool, error)

Returns the command output, whether the exit was ok, and any errors

func RunSshCommand

func RunSshCommand(cmd string, args ...string) (string, error)

runSshCommand executes the ssh or scp command, adding the flag provided --ssh-options

Types

type ConformanceContainer

type ConformanceContainer struct {
	Framework        *framework.Framework
	Container        api.Container
	RestartPolicy    api.RestartPolicy
	Volumes          []api.Volume
	ImagePullSecrets []string

	PodSecurityContext *api.PodSecurityContext
	// contains filtered or unexported fields
}

One pod one container TODO: This should be migrated to the e2e framework.

func (*ConformanceContainer) Create

func (cc *ConformanceContainer) Create()

func (*ConformanceContainer) Delete

func (cc *ConformanceContainer) Delete() error

func (*ConformanceContainer) GetPhase

func (cc *ConformanceContainer) GetPhase() (api.PodPhase, error)

func (*ConformanceContainer) GetStatus

func (cc *ConformanceContainer) GetStatus() (api.ContainerStatus, error)

func (*ConformanceContainer) IsReady

func (cc *ConformanceContainer) IsReady() (bool, error)

func (*ConformanceContainer) Present

func (cc *ConformanceContainer) Present() (bool, error)

type ConformanceImage

type ConformanceImage struct {
	Image   kubecontainer.ImageSpec
	Runtime kubecontainer.Runtime
}

func NewConformanceImage

func NewConformanceImage(containerRuntime string, image string) (ci ConformanceImage, err error)

func (*ConformanceImage) GetTag

func (ci *ConformanceImage) GetTag() string

func (*ConformanceImage) List

func (ci *ConformanceImage) List() ([]string, error)

func (*ConformanceImage) Present

func (ci *ConformanceImage) Present() (bool, error)

func (*ConformanceImage) Pull

func (ci *ConformanceImage) Pull() error

func (*ConformanceImage) Remove

func (ci *ConformanceImage) Remove() error

type ContainerState

type ContainerState int

const (
	ContainerStateWaiting ContainerState = iota
	ContainerStateRunning
	ContainerStateTerminated
	ContainerStateUnknown
)

func GetContainerState

func GetContainerState(state api.ContainerState) ContainerState