kubernetesk8s.io/kubernetes/test/e2e/apps Index | Files

package apps

import "k8s.io/kubernetes/test/e2e/apps"

Index

Constants

const (

	// ADD represents the ADD event
	ADD = "ADD"
	// DEL represents the DEL event
	DEL = "DEL"
	// UPDATE represents the UPDATE event
	UPDATE = "UPDATE"
)
const (
	WebserverImageName = "httpd"
	AgnhostImageName   = "agnhost"
)

NOTE(claudiub): These constants should NOT be used as Pod Container Images.

const (

	// JobTimeout is how long to wait for a job to finish.
	JobTimeout = 15 * time.Minute
)

Variables

var (
	// WebserverImage is the fully qualified URI to the Httpd image
	WebserverImage = imageutils.GetE2EImage(imageutils.Httpd)

	// NewWebserverImage is the fully qualified URI to the HttpdNew image
	NewWebserverImage = imageutils.GetE2EImage(imageutils.HttpdNew)

	// AgnhostImage is the fully qualified URI to the Agnhost image
	AgnhostImage = imageutils.GetE2EImage(imageutils.Agnhost)
)
var NamespaceNodeSelectors = []string{"scheduler.alpha.kubernetes.io/node-selector"}

NamespaceNodeSelectors the annotation key scheduler.alpha.kubernetes.io/node-selector is for assigning node selectors labels to namespaces

var SIGDescribe = framework.SIGDescribe("apps")

SIGDescribe annotates the test with the SIG label.

Functions

func TestReplicationControllerServeImageOrFail

func TestReplicationControllerServeImageOrFail(ctx context.Context, f *framework.Framework, test string, image string)

TestReplicationControllerServeImageOrFail is a basic test to check the deployment of an image using a replication controller. The image serves its hostname which is checked for each replica.

Types

type IndexedPodAnnotationTracker

type IndexedPodAnnotationTracker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewIndexedPodAnnotationTracker

func NewIndexedPodAnnotationTracker(ownerName, ownerNs, labelSelector, podIndexAnnotation, podTrackedAnnotation string) *IndexedPodAnnotationTracker

func (*IndexedPodAnnotationTracker) Start

type RestartDaemonConfig

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

RestartDaemonConfig is a config to restart a running daemon on a node, and wait till it comes back up. It uses ssh to send a SIGTERM to the daemon.

func NewRestartConfig

func NewRestartConfig(nodeName, daemonName string, healthzPort int, pollInterval, pollTimeout time.Duration, enableHTTPS bool) *RestartDaemonConfig

NewRestartConfig creates a RestartDaemonConfig for the given node and daemon.

func (*RestartDaemonConfig) String

func (r *RestartDaemonConfig) String() string

Source Files

controller_revision.go cronjob.go daemon_restart.go daemon_set.go deployment.go disruption.go framework.go job.go rc.go replica_set.go statefulset.go ttl_after_finished.go types.go util.go wait.go

Version
v1.33.0 (latest)
Published
Apr 23, 2025
Platform
linux/amd64
Imports
93 packages
Last checked
3 hours ago

Tools for package owners.