package e2e_node

import "k8s.io/kubernetes/test/e2e_node"

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 PrePullAllImages() error
• func RunE2EServices()
• func RunRemote(archive string, host string, cleanup bool, junitFilePrefix string, setupNode bool, testArgs string, ginkgoFlags string) (string, bool, error)
• func RunSshCommand(cmd string, args ...string) (string, error)
• type APIServer
• func NewAPIServer() *APIServer
• func (a *APIServer) Name() string
• func (a *APIServer) Start() error
• func (a *APIServer) Stop() 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
• type E2EServices
• func NewE2EServices() *E2EServices
• func (e *E2EServices) Start() error
• func (e *E2EServices) Stop() error
• type EtcdServer
• func NewEtcd(dataDir string) *EtcdServer
• func (e *EtcdServer) Name() string
• func (e *EtcdServer) Start() error
• func (e *EtcdServer) Stop() error
• type NamespaceController
• func NewNamespaceController() *NamespaceController
• func (n *NamespaceController) Name() string
• func (n *NamespaceController) Start() error
• func (n *NamespaceController) Stop() error

Constants ¶

const (
	CNIRelease   = "8a936732094c0941e1543ef5d292a1f4fffa1ac5"
	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 PrePullAllImages ¶

func PrePullAllImages() error

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

func RunE2EServices ¶

func RunE2EServices()

RunE2EServices actually start the e2e services. This function is used to start e2e services in current process. This is only used in run-services-mode.

func RunRemote ¶

func RunRemote(archive string, host string, cleanup bool, junitFilePrefix string, setupNode bool, testArgs string, ginkgoFlags string) (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 APIServer ¶

type APIServer struct{}

APIServer is a server which manages apiserver.

func NewAPIServer ¶

func NewAPIServer() *APIServer

NewAPIServer creates an apiserver.

func (*APIServer) Name ¶

func (a *APIServer) Name() string

func (*APIServer) Start ¶

func (a *APIServer) Start() error

Start starts the apiserver, returns when apiserver is ready.

func (*APIServer) Stop ¶

func (a *APIServer) Stop() error

Stop stops the apiserver. Currently, there is no way to stop the apiserver. The function is here only for completion.

type ConformanceContainer ¶

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

	PodClient *framework.PodClient

	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

type E2EServices ¶

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

E2EServices starts and stops e2e services in a separate process. The test uses it to start and stop all e2e services.

func NewE2EServices ¶

func NewE2EServices() *E2EServices

func (*E2EServices) Start ¶

func (e *E2EServices) Start() error

Start starts the e2e services in another process, it returns when all e2e services are ready. We want to statically link e2e services into the test binary, but we don't want their glog to pollute the test result. So we run the binary in run- services-mode to start e2e services in another process.

func (*E2EServices) Stop ¶

func (e *E2EServices) Stop() error

Stop stops the e2e services.

type EtcdServer ¶

type EtcdServer struct {
	*etcdserver.EtcdServer
	// contains filtered or unexported fields
}

EtcdServer is a server which manages etcd.

func NewEtcd ¶

func NewEtcd(dataDir string) *EtcdServer

NewEtcd creates a new default etcd server using 'dataDir' for persistence.

func (*EtcdServer) Name ¶

func (e *EtcdServer) Name() string

Name returns the server's unique name

func (*EtcdServer) Start ¶

func (e *EtcdServer) Start() error

Start starts the etcd server and listening for client connections

func (*EtcdServer) Stop ¶

func (e *EtcdServer) Stop() error

Stop closes all connections and stops the Etcd server

type NamespaceController ¶

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

NamespaceController is a server which manages namespace controller.

func NewNamespaceController ¶

func NewNamespaceController() *NamespaceController

NewNamespaceController creates a new namespace controller.

func (*NamespaceController) Name ¶

func (n *NamespaceController) Name() string

Name returns the name of namespace controller.

func (*NamespaceController) Start ¶

func (n *NamespaceController) Start() error

Start starts the namespace controller.

func (*NamespaceController) Stop ¶

func (n *NamespaceController) Stop() error

Stop stops the namespace controller.

Source Files ¶

apiserver.go container.go doc.go e2e_build.go e2e_remote.go e2e_service.go etcd.go image.go image_list.go namespace_controller.go util.go

Directories ¶