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 ¶

• func CContainerEqual(expected interface{}) types.GomegaMatcher
• func CreateTestArchive() string
• func NewDefaultFramework(baseName string) *framework.Framework
• func RunRemote(archive string, host string, cleanup bool) (string, error)
• func RunSshCommand(cmd string, args ...string) (string, error)
• type ConformanceContainer
• func (cc *ConformanceContainer) Create() error
• func (cc *ConformanceContainer) Delete() error
• func (cc *ConformanceContainer) Get() (ConformanceContainer, error)
• func (cc *ConformanceContainer) GetStatus() (api.ContainerStatus, api.PodPhase, error)
• func (cc *ConformanceContainer) Present() (bool, error)
• func (cc *ConformanceContainer) Stop() error
• type ConformanceContainerEqualMatcher
• func (matcher *ConformanceContainerEqualMatcher) FailureMessage(actual interface{}) (message string)
• func (matcher *ConformanceContainerEqualMatcher) Match(actual interface{}) (bool, error)
• func (matcher *ConformanceContainerEqualMatcher) NegatedFailureMessage(actual interface{}) (message string)
• 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

Functions ¶

func CContainerEqual ¶

func CContainerEqual(expected interface{}) types.GomegaMatcher

func CreateTestArchive ¶

func CreateTestArchive() string

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 NewDefaultFramework ¶

func NewDefaultFramework(baseName string) *framework.Framework

func RunRemote ¶

func RunRemote(archive string, host string, cleanup bool) (string, error)

RunRemote copies the archive file to a /tmp file on host, unpacks it, and runs the e2e_node.test

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 {
	Container     api.Container
	Client        *client.Client
	RestartPolicy api.RestartPolicy
	Volumes       []api.Volume
	NodeName      string
	Namespace     string
	// contains filtered or unexported fields
}

One pod one container

func (*ConformanceContainer) Create ¶

func (cc *ConformanceContainer) Create() error

func (*ConformanceContainer) Delete ¶

func (cc *ConformanceContainer) Delete() error

func (*ConformanceContainer) Get ¶

func (cc *ConformanceContainer) Get() (ConformanceContainer, error)

func (*ConformanceContainer) GetStatus ¶

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

func (*ConformanceContainer) Present ¶

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

func (*ConformanceContainer) Stop ¶

func (cc *ConformanceContainer) Stop() error

Same with 'delete'

type ConformanceContainerEqualMatcher ¶

type ConformanceContainerEqualMatcher struct {
	Expected interface{}
}

func (*ConformanceContainerEqualMatcher) FailureMessage ¶

func (matcher *ConformanceContainerEqualMatcher) FailureMessage(actual interface{}) (message string)

func (*ConformanceContainerEqualMatcher) Match ¶

func (matcher *ConformanceContainerEqualMatcher) Match(actual interface{}) (bool, error)

func (*ConformanceContainerEqualMatcher) NegatedFailureMessage ¶

func (matcher *ConformanceContainerEqualMatcher) NegatedFailureMessage(actual interface{}) (message string)

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 uint32

const (
	ContainerStateWaiting ContainerState = 1 << iota
	ContainerStateRunning
	ContainerStateTerminated
	ContainerStateUnknown
)

func GetContainerState ¶

func GetContainerState(state api.ContainerState) ContainerState

Source Files ¶

container.go doc.go e2e_build.go e2e_remote.go e2e_service.go exec_util.go image.go util.go

Directories ¶