...

Package node

import "k8s.io/kubernetes/test/e2e/common/node"
Overview
Index

Overview ▾

Constants

const (
    // ContainerStatusRetryTimeout represents polling threshold before giving up to get the container status
    ContainerStatusRetryTimeout = time.Minute * 5
    // ContainerStatusPollInterval represents duration between polls to get the container status
    ContainerStatusPollInterval = time.Second * 1
)

Variables

var SIGDescribe = framework.SIGDescribe("node")

func GetContainerStartedTime

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

GetContainerStartedTime returns the time when the given container started and error if any

func GetTransitionTimeForReadyCondition

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

GetTransitionTimeForReadyCondition returns the time when the given pod became ready and error if any

func RunLivenessTest

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

func RunSidecarLivenessTest

func RunSidecarLivenessTest(ctx context.Context, f *framework.Framework, pod *v1.Pod, expectNumRestarts int, timeout time.Duration)

type ConformanceContainer

ConformanceContainer defines the types for running container conformance test cases One pod one container

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

    PodClient *e2epod.PodClient

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

func (*ConformanceContainer) Create

func (cc *ConformanceContainer) Create(ctx context.Context)

Create creates the defined conformance container

func (*ConformanceContainer) Delete

func (cc *ConformanceContainer) Delete(ctx context.Context) error

Delete deletes the defined conformance container

func (*ConformanceContainer) GetPhase

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

GetPhase returns the phase of the pod lifecycle and error if any

func (*ConformanceContainer) GetStatus

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

GetStatus returns the details of the current status of this container and error if any

func (*ConformanceContainer) IsReady

func (cc *ConformanceContainer) IsReady(ctx context.Context) (bool, error)

IsReady returns whether this container is ready and error if any

func (*ConformanceContainer) Present

func (cc *ConformanceContainer) Present(ctx context.Context) (bool, error)

Present returns whether this pod is present and error if any

type ContainerState

ContainerState represents different states of its lifecycle

type ContainerState string
const (
    // ContainerStateWaiting represents 'Waiting' container state
    ContainerStateWaiting ContainerState = "Waiting"
    // ContainerStateRunning represents 'Running' container state
    ContainerStateRunning ContainerState = "Running"
    // ContainerStateTerminated represents 'Terminated' container state
    ContainerStateTerminated ContainerState = "Terminated"
    // ContainerStateUnknown represents 'Unknown' container state
    ContainerStateUnknown ContainerState = "Unknown"
)

func GetContainerState

func GetContainerState(state v1.ContainerState) ContainerState

GetContainerState returns current state the container represents among its lifecycle

type KubeletManagedHostConfig

KubeletManagedHostConfig defines the types for running managed etc hosts test cases

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

type PrivilegedPodTestConfig

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

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