const nonExist … func removePtr(replicas *int32) int32 { … } func waitUntilPodIsScheduled(ctx context.Context, c clientset.Interface, name, namespace string, timeout time.Duration) (*v1.Pod, error) { … } func RunPodAndGetNodeName(ctx context.Context, c clientset.Interface, pod *v1.Pod, timeout time.Duration) (string, error) { … } type RunObjectConfig … type RCConfig … func (rc *RCConfig) RCConfigLog(fmt string, args ...interface{ … } type DeploymentConfig … type ReplicaSetConfig … type JobConfig … type podInfo … type podDiff … // Print formats and prints the give podDiff. func (p podDiff) String(ignorePhases sets.String) string { … } // DeletedPods returns a slice of pods that were present at the beginning // and then disappeared. func (p podDiff) DeletedPods() []string { … } // diff computes a podDiff given 2 lists of pods. func diff(oldPods []*v1.Pod, curPods []*v1.Pod) podDiff { … } // RunDeployment Launches (and verifies correctness) of a Deployment // and will wait for all pods it spawns to become "Running". // It's the caller's responsibility to clean up externally (i.e. use the // namespace lifecycle for handling Cleanup). func RunDeployment(ctx context.Context, config DeploymentConfig) error { … } func (config *DeploymentConfig) create() error { … } // RunReplicaSet launches (and verifies correctness) of a ReplicaSet // and waits until all the pods it launches to reach the "Running" state. // It's the caller's responsibility to clean up externally (i.e. use the // namespace lifecycle for handling Cleanup). func RunReplicaSet(ctx context.Context, config ReplicaSetConfig) error { … } func (config *ReplicaSetConfig) create() error { … } // RunRC Launches (and verifies correctness) of a Replication Controller // and will wait for all pods it spawns to become "Running". // It's the caller's responsibility to clean up externally (i.e. use the // namespace lifecycle for handling Cleanup). func RunRC(ctx context.Context, config RCConfig) error { … } func (config *RCConfig) create() error { … } func (config *RCConfig) applyTo(template *v1.PodTemplateSpec) { … } type RCStartupStatus … func (s *RCStartupStatus) String(name string) string { … } func computeRCStartupStatus(pods []*v1.Pod, expected int) RCStartupStatus { … } func (config *RCConfig) start(ctx context.Context) error { … } // Simplified version of RunRC, that does not create RC, but creates plain Pods. // Optionally waits for pods to start running (if waitForRunning == true). // The number of replicas must be non-zero. func StartPods(c clientset.Interface, replicas int, namespace string, podNamePrefix string, pod v1.Pod, waitForRunning bool, logFunc func(fmt string, args ...interface{ … } // Wait up to 10 minutes for all matching pods to become Running and at least one // matching pod exists. func WaitForPodsWithLabelRunning(c clientset.Interface, ns string, label labels.Selector) error { … } // Wait up to 10 minutes for at least 'replicas' many pods to be Running and at least // one matching pod exists. If 'replicas' is < 0, wait for all matching pods running. func WaitForEnoughPodsWithLabelRunning(c clientset.Interface, ns string, label labels.Selector, replicas int) error { … } type PrepareNodeStrategy … type TrivialNodePrepareStrategy … var _ … func (*TrivialNodePrepareStrategy) PreparePatch(*v1.Node) []byte { … } func (*TrivialNodePrepareStrategy) CleanupNode(ctx context.Context, node *v1.Node) *v1.Node { … } func (*TrivialNodePrepareStrategy) PrepareDependentObjects(ctx context.Context, node *v1.Node, client clientset.Interface) error { … } func (*TrivialNodePrepareStrategy) CleanupDependentObjects(ctx context.Context, nodeName string, client clientset.Interface) error { … } type LabelNodePrepareStrategy … var _ … func NewLabelNodePrepareStrategy(labelKey string, labelValues ...string) *LabelNodePrepareStrategy { … } func (s *LabelNodePrepareStrategy) PreparePatch(*v1.Node) []byte { … } func (s *LabelNodePrepareStrategy) CleanupNode(ctx context.Context, node *v1.Node) *v1.Node { … } func (*LabelNodePrepareStrategy) PrepareDependentObjects(ctx context.Context, node *v1.Node, client clientset.Interface) error { … } func (*LabelNodePrepareStrategy) CleanupDependentObjects(ctx context.Context, nodeName string, client clientset.Interface) error { … } type NodeAllocatableStrategy … var _ … func NewNodeAllocatableStrategy(nodeAllocatable map[v1.ResourceName]string, csiNodeAllocatable map[string]*storagev1.VolumeNodeResources, migratedPlugins []string) *NodeAllocatableStrategy { … } func (s *NodeAllocatableStrategy) PreparePatch(node *v1.Node) []byte { … } func (s *NodeAllocatableStrategy) CleanupNode(ctx context.Context, node *v1.Node) *v1.Node { … } func (s *NodeAllocatableStrategy) createCSINode(ctx context.Context, nodeName string, client clientset.Interface) error { … } func (s *NodeAllocatableStrategy) updateCSINode(ctx context.Context, csiNode *storagev1.CSINode, client clientset.Interface) error { … } func (s *NodeAllocatableStrategy) PrepareDependentObjects(ctx context.Context, node *v1.Node, client clientset.Interface) error { … } func (s *NodeAllocatableStrategy) CleanupDependentObjects(ctx context.Context, nodeName string, client clientset.Interface) error { … } type UniqueNodeLabelStrategy … var _ … func NewUniqueNodeLabelStrategy(labelKey string) *UniqueNodeLabelStrategy { … } func (s *UniqueNodeLabelStrategy) PreparePatch(*v1.Node) []byte { … } func (s *UniqueNodeLabelStrategy) CleanupNode(ctx context.Context, node *v1.Node) *v1.Node { … } func (*UniqueNodeLabelStrategy) PrepareDependentObjects(ctx context.Context, node *v1.Node, client clientset.Interface) error { … } func (*UniqueNodeLabelStrategy) CleanupDependentObjects(ctx context.Context, nodeName string, client clientset.Interface) error { … } func DoPrepareNode(ctx context.Context, client clientset.Interface, node *v1.Node, strategy PrepareNodeStrategy) error { … } type TestPodCreateStrategy … type CountToPodStrategy … type TestPodCreatorConfig … func NewTestPodCreatorConfig() *TestPodCreatorConfig { … } type CountToStrategy … type TestNodePreparer … func (c *TestPodCreatorConfig) AddStrategy( namespace string, podCount int, strategy TestPodCreateStrategy) { … } type TestPodCreator … func NewTestPodCreator(client clientset.Interface, config *TestPodCreatorConfig) *TestPodCreator { … } func (c *TestPodCreator) CreatePods(ctx context.Context) error { … } func MakePodSpec() v1.PodSpec { … } func makeCreatePod(client clientset.Interface, namespace string, podTemplate *v1.Pod) error { … } func CreatePod(ctx context.Context, client clientset.Interface, namespace string, podCount int, podTemplate PodTemplate) error { … } func CreatePodWithPersistentVolume(ctx context.Context, client clientset.Interface, namespace string, claimTemplate *v1.PersistentVolumeClaim, factory volumeFactory, podTemplate PodTemplate, count int, bindVolume bool) error { … } func NewCustomCreatePodStrategy(podTemplate PodTemplate) TestPodCreateStrategy { … } type volumeFactory … type PodTemplate … // StaticPodTemplate returns an implementation of PodTemplate for a fixed pod that is the same regardless of the index. func StaticPodTemplate(pod *v1.Pod) PodTemplate { … } type staticPodTemplate … // GetPodTemplate implements [PodTemplate.GetPodTemplate] by returning the same pod // for each call. func (s *staticPodTemplate) GetPodTemplate(index, count int) (*v1.Pod, error) { … } func NewCreatePodWithPersistentVolumeStrategy(claimTemplate *v1.PersistentVolumeClaim, factory volumeFactory, podTemplate PodTemplate) TestPodCreateStrategy { … } // TODO: attach secrets using different possibilities: env vars, image pull secrets. func attachSecrets(template *v1.PodTemplateSpec, secretNames []string) { … } // TODO: attach configmaps using different possibilities: env vars. func attachConfigMaps(template *v1.PodTemplateSpec, configMapNames []string) { … } func (config *RCConfig) getTerminationGracePeriodSeconds(defaultGrace *int64) *int64 { … } func attachServiceAccountTokenProjection(template *v1.PodTemplateSpec, name string) { … }
Codebase Browser
kubernetes