node

Documentation

Index

• Constants
• Variables
• func GetContainerStartedTime(p *v1.Pod, containerName string) (time.Time, error)
• func GetTransitionTimeForReadyCondition(p *v1.Pod) (time.Time, error)
• func RunLivenessTest(ctx context.Context, f *framework.Framework, pod *v1.Pod, ...)
• func RunSidecarLivenessTest(ctx context.Context, f *framework.Framework, pod *v1.Pod, ...)
• type ConformanceContainer
  • func (cc *ConformanceContainer) Create(ctx context.Context)
  • func (cc *ConformanceContainer) Delete(ctx context.Context) error
  • func (cc *ConformanceContainer) GetPhase(ctx context.Context) (v1.PodPhase, error)
  • func (cc *ConformanceContainer) GetStatus(ctx context.Context) (v1.ContainerStatus, error)
  • func (cc *ConformanceContainer) IsReady(ctx context.Context) (bool, error)
  • func (cc *ConformanceContainer) Present(ctx context.Context) (bool, error)
• type ContainerState
  • func GetContainerState(state v1.ContainerState) ContainerState
• type KubeletManagedHostConfig
• type PrivilegedPodTestConfig

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

Functions

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)

Types

type ConformanceContainer

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
}

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

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

type ContainerState string

ContainerState represents different states of its lifecycle

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

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

KubeletManagedHostConfig defines the types for running managed etc hosts test cases

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