common

Documentation

Index

• Constants
• Variables
• func GetContainerStartedTime(p *v1.Pod, containerName string) (time.Time, error)
• func GetTransitionTimeForReadyCondition(p *v1.Pod) (time.Time, error)
• func NewRCByName(c clientset.Interface, ns, name string, replicas int32, gracePeriod *int64, ...) (*v1.ReplicationController, error)
• func NewSVCByName(c clientset.Interface, ns, name string) error
• func RestartNodes(c clientset.Interface, nodes []v1.Node) error
• func RunLivenessTest(f *framework.Framework, pod *v1.Pod, expectNumRestarts int, ...)
• func SubstituteImageName(content string) string
• type ConformanceContainer
  • func (cc *ConformanceContainer) Create()
  • func (cc *ConformanceContainer) Delete() error
  • func (cc *ConformanceContainer) GetPhase() (v1.PodPhase, error)
  • func (cc *ConformanceContainer) GetStatus() (v1.ContainerStatus, error)
  • func (cc *ConformanceContainer) IsReady() (bool, error)
  • func (cc *ConformanceContainer) Present() (bool, error)
• type ContainerState
  • func GetContainerState(state v1.ContainerState) ContainerState
• type KubeletManagedHostConfig
• type PrivilegedPodTestConfig
• type Suite

Constants

const (
	ContainerStatusRetryTimeout = time.Minute * 5
	ContainerStatusPollInterval = time.Second * 1
)

Variables

var PrePulledImages = sets.NewString(
	imageutils.GetE2EImage(imageutils.Agnhost),
	imageutils.GetE2EImage(imageutils.BusyBox),
	imageutils.GetE2EImage(imageutils.IpcUtils),
	imageutils.GetE2EImage(imageutils.Nginx),
	imageutils.GetE2EImage(imageutils.Httpd),
	imageutils.GetE2EImage(imageutils.VolumeNFSServer),
	imageutils.GetE2EImage(imageutils.VolumeGlusterServer),
	imageutils.GetE2EImage(imageutils.NonRoot),
)

PrePulledImages are a list of images used in e2e/common tests. These images should be prepulled before tests starts, so that the tests won't fail due image pulling flakes. Currently, this is only used by node e2e test. See also updateImageAllowList() in ../../e2e_node/image_list.go TODO(random-liu): Change the image puller pod to use similar mechanism.

Functions

func GetContainerStartedTime

func GetContainerStartedTime(p *v1.Pod, containerName string) (time.Time, error)

func GetTransitionTimeForReadyCondition

func GetTransitionTimeForReadyCondition(p *v1.Pod) (time.Time, error)

func NewRCByName

func NewRCByName(c clientset.Interface, ns, name string, replicas int32, gracePeriod *int64, containerArgs []string) (*v1.ReplicationController, error)

NewRCByName creates a replication controller with a selector by name of name.

func NewSVCByName

func NewSVCByName(c clientset.Interface, ns, name string) error

NewSVCByName creates a service by name.

func RestartNodes

func RestartNodes(c clientset.Interface, nodes []v1.Node) error

RestartNodes restarts specific nodes.

func RunLivenessTest

func RunLivenessTest(f *framework.Framework, pod *v1.Pod, expectNumRestarts int, timeout time.Duration)

func SubstituteImageName

func SubstituteImageName(content string) string

SubstituteImageName replaces image name in content.

Types

type ConformanceContainer

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

	PodClient *framework.PodClient

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

One pod one container

func (*ConformanceContainer) Create

func (cc *ConformanceContainer) Create()

func (*ConformanceContainer) Delete

func (cc *ConformanceContainer) Delete() error

func (*ConformanceContainer) GetPhase

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

func (*ConformanceContainer) GetStatus

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

func (*ConformanceContainer) IsReady

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

func (*ConformanceContainer) Present

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

type ContainerState

type ContainerState string

const (
	ContainerStateWaiting    ContainerState = "Waiting"
	ContainerStateRunning    ContainerState = "Running"
	ContainerStateTerminated ContainerState = "Terminated"
	ContainerStateUnknown    ContainerState = "Unknown"
)

func GetContainerState

func GetContainerState(state v1.ContainerState) ContainerState

type KubeletManagedHostConfig

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

type PrivilegedPodTestConfig

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

PrivilegedPodTestConfig is configuration struct for privileged pod test TODO: Merge with tests in security_context.go

type Suite

type Suite string

Suite represents test suite.

const (
	// E2E represents a test suite for e2e.
	E2E Suite = "e2e"
	// NodeE2E represents a test suite for node e2e.
	NodeE2E Suite = "node e2e"
)

var CurrentSuite Suite

CurrentSuite represents current test suite.