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

• func CContainerEqual(expected interface{}) types.GomegaMatcher
• func CreateTestArchive() string
• func RunRemote(archive string, host string, deleteFiles 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) 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) List() ([]string, error)
  • func (ci *ConformanceImage) Pull() error
  • func (ci *ConformanceImage) Remove() error

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 RunRemote

func RunRemote(archive string, host string, deleteFiles 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
	Phase     api.PodPhase
	NodeName  string
}

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) 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) List

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

func (*ConformanceImage) Pull

func (ci *ConformanceImage) Pull() error

func (*ConformanceImage) Remove

func (ci *ConformanceImage) Remove() error