Versions in this module Expand all Collapse all v0 v0.37.1 Oct 13, 2026 v0.37.0 Oct 13, 2026 Changes in this version + const DefaultWaitTimeout + const KubernetesVersion + func Retry(t testing.TB, cond func(context.Context) (bool, error), opts ...WaitOption) + func RetryUntil(ctx context.Context, cond func(context.Context) (bool, error), ...) error + func WaitFor[O runtime.Object](t testing.TB, client ObjectClient[O], name string, cond Condition[O], ...) O + func WaitUntil[O runtime.Object](ctx context.Context, client ObjectClient[O], name string, cond Condition[O], ...) (O, error) + type AdmissionWebhookOptions struct + Host string + Namespace string + Port int + type Condition func(O) (bool, error) + func Deleted[O runtime.Object]() Condition[O] + func Exists[O runtime.Object]() Condition[O] + func StatusCondition[O runtime.Object](condType string, status metav1.ConditionStatus) Condition[O] + type ControlPlane struct + func New(ctx context.Context, opts ...Option) (*ControlPlane, error) + func Start(t testing.TB) *ControlPlane + func (cp *ControlPlane) AddNode(t testing.TB, opts NodeOptions) *Node + func (cp *ControlPlane) AddNodeCtx(ctx context.Context, opts NodeOptions) (*Node, error) + func (cp *ControlPlane) Bind(t testing.TB, pod *corev1.Pod, node *Node) + func (cp *ControlPlane) BindCtx(ctx context.Context, pod *corev1.Pod, node *Node) error + func (cp *ControlPlane) Client() *kubernetes.Clientset + func (cp *ControlPlane) CompletePod(t testing.TB, pod *corev1.Pod) + func (cp *ControlPlane) CompletePodCtx(ctx context.Context, pod *corev1.Pod) error + func (cp *ControlPlane) Config() *rest.Config + func (cp *ControlPlane) EnableControllers(t testing.TB, cs ...Controller) + func (cp *ControlPlane) Evict(t testing.TB, pod *corev1.Pod) + func (cp *ControlPlane) EvictCtx(ctx context.Context, pod *corev1.Pod) error + func (cp *ControlPlane) ExpectPod(t testing.TB, matchers ...PodMatcher) *corev1.Pod + func (cp *ControlPlane) ExpectPodCtx(ctx context.Context, matchers ...PodMatcher) (*corev1.Pod, error) + func (cp *ControlPlane) ExpectPods(t testing.TB, matchers ...PodMatcher) *PodExpectation + func (cp *ControlPlane) ExpectPodsCtx(ctx context.Context, matchers ...PodMatcher) (*PodExpectation, error) + func (cp *ControlPlane) FailPod(t testing.TB, pod *corev1.Pod, exitCode int32) + func (cp *ControlPlane) FailPodCtx(ctx context.Context, pod *corev1.Pod, exitCode int32) error + func (cp *ControlPlane) InstallAdmissionWebhooks(t testing.TB, opts AdmissionWebhookOptions, sources ...any) + func (cp *ControlPlane) InstallAdmissionWebhooksCtx(ctx context.Context, opts AdmissionWebhookOptions, sources ...any) (func() error, error) + func (cp *ControlPlane) InstallCRDs(t testing.TB, sources ...any) + func (cp *ControlPlane) InstallCRDsCtx(ctx context.Context, sources ...any) error + func (cp *ControlPlane) InstallConversionWebhooks(t testing.TB, opts ConversionWebhookOptions, crdNames ...string) + func (cp *ControlPlane) InstallConversionWebhooksCtx(ctx context.Context, opts ConversionWebhookOptions, crdNames ...string) error + func (cp *ControlPlane) Namespace(t testing.TB) string + func (cp *ControlPlane) NewNamespace(ctx context.Context) (string, error) + func (cp *ControlPlane) ServingCertDir(t testing.TB) string + func (cp *ControlPlane) SetPodReady(t testing.TB, pod *corev1.Pod, ready bool) + func (cp *ControlPlane) SetPodReadyCtx(ctx context.Context, pod *corev1.Pod, ready bool) error + func (cp *ControlPlane) Stop() error + func (cp *ControlPlane) StrictPods(t testing.TB) + func (cp *ControlPlane) StrictPodsCtx(ctx context.Context) error + func (cp *ControlPlane) UnexpectedPods() []string + func (cp *ControlPlane) WebhookCABundle() []byte + func (cp *ControlPlane) WriteServingCert(dir string) error + type Controller string + const CronJobController + const DaemonSetController + const DeploymentController + const DisruptionController + const EndpointSliceController + const JobController + const ReplicaSetController + const ResourceQuotaController + const SchedulerController + const ServiceAccountController + const ServiceAccountTokenController + const StatefulSetController + const TTLAfterFinishedController + func WorkloadControllers() []Controller + type ConversionWebhookOptions struct + Host string + Port int + type Node struct + func (n *Node) Cordon(t testing.TB) + func (n *Node) CordonCtx(ctx context.Context) error + func (n *Node) Delete(t testing.TB) + func (n *Node) DeleteCtx(ctx context.Context) error + func (n *Node) Drain(t testing.TB, opts ...WaitOption) + func (n *Node) DrainCtx(ctx context.Context, opts ...WaitOption) error + func (n *Node) Name() string + func (n *Node) SetReady(t testing.TB, ready bool) + func (n *Node) SetReadyCtx(ctx context.Context, ready bool) error + func (n *Node) Taint(t testing.TB, taints ...corev1.Taint) + func (n *Node) TaintCtx(ctx context.Context, taints ...corev1.Taint) error + func (n *Node) Uncordon(t testing.TB) + func (n *Node) UncordonCtx(ctx context.Context) error + func (n *Node) Untaint(t testing.TB, taints ...corev1.Taint) + func (n *Node) UntaintCtx(ctx context.Context, taints ...corev1.Taint) error + type NodeOptions struct + Annotations map[string]string + Capacity corev1.ResourceList + Labels map[string]string + Name string + Taints []corev1.Taint + Unschedulable bool + type ObjectClient interface + Get func(ctx context.Context, name string, opts metav1.GetOptions) (O, error) + Watch func(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) + func DynamicResource(ri dynamic.ResourceInterface) ObjectClient[*unstructured.Unstructured] + type Option func(*startOptions) + func WithoutDefaultControllers() Option + type PodExpectation struct + func (e *PodExpectation) AnyTimes() *PodExpectation + func (e *PodExpectation) BindTo(node *Node) *PodExpectation + func (e *PodExpectation) Do(action func(ctx context.Context, pod *corev1.Pod) error) *PodExpectation + func (e *PodExpectation) Pods() []*corev1.Pod + func (e *PodExpectation) Times(n int) *PodExpectation + func (e *PodExpectation) Verify(ctx context.Context) error + func (e *PodExpectation) Wait(t testing.TB, opts ...WaitOption) + func (e *PodExpectation) WaitCtx(ctx context.Context, opts ...WaitOption) error + type PodMatcher struct + func InNamespace(namespace string) PodMatcher + func Labeled(key, value string) PodMatcher + func OwnedBy(owner metav1.Object) PodMatcher + func PodMatching(desc string, match func(*corev1.Pod) bool) PodMatcher + func (m PodMatcher) String() string + type WaitOption func(*waitConfig) + func WithTimeout(d time.Duration) WaitOption
Go to main page