framework

Aug 5, 2024

Changes in this version

+ func Filter(nodeList *v1.NodeList, fn func(node v1.Node) bool)

+ func GetRandomReadySchedulableNode(ctx context.Context, c clientset.Interface) (*v1.Node, error)

+ func GetReadySchedulableNodes(ctx context.Context, c clientset.Interface) (nodes *v1.NodeList, err error)

+ func IsConditionSetAsExpected(node *v1.Node, conditionType v1.NodeConditionType, wantTrue bool) bool

+ func IsConditionSetAsExpectedSilent(node *v1.Node, conditionType v1.NodeConditionType, wantTrue bool) bool

+ func IsNodeReady(node *v1.Node) bool

+ func IsNodeSchedulable(node *v1.Node) bool

+ func SortStatefulPods(pods *v1.PodList)

+ func WaitForNodeSchedulable(ctx context.Context, c clientset.Interface, name string, timeout time.Duration, ...) bool

type Framework

+ func (f *Framework) WithDisruptive() interface{}

+ func (f *Framework) WithSerial() interface{}

type StatefulSetTester

+ func (s *StatefulSetTester) WaitForPodUpdatedAndRunning(set *appsv1beta1.StatefulSet, podName string, currentRevision string) (*appsv1beta1.StatefulSet, *v1.PodList)

Mar 15, 2024

Changes in this version

type PodProbeMarkerTester

+ func (s *PodProbeMarkerTester) NewPodProbeMarkerForTcpCheck(ns, randStr string) []appsv1alpha1.PodProbeMarker

Jan 26, 2024

Changes in this version

type PodProbeMarkerTester

+ func (s *PodProbeMarkerTester) NewPodProbeMarkerWithProbeImg(ns, randStr string) appsv1alpha1.PodProbeMarker

+ func (s *PodProbeMarkerTester) NewStatefulSetWithProbeImg(namespace, randStr string) *appsv1beta1.StatefulSet

Dec 18, 2023

Changes in this version

type SidecarSetTester

+ func (s *SidecarSetTester) UpdateDeployment(obj *apps.Deployment)

+ type UnitedDeploymentManager struct

+ func (m *UnitedDeploymentManager) AddSubset(name string, replicas, minReplicas, maxReplicas *intstr.IntOrString)

+ func (m *UnitedDeploymentManager) CheckSubsets(replicas map[string]int32)

+ func (m *UnitedDeploymentManager) Create(replicas int32)

+ func (m *UnitedDeploymentManager) Scale(replicas int32)

+ type UnitedDeploymentTester struct

+ func NewUnitedDeploymentTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *UnitedDeploymentTester

+ func (t *UnitedDeploymentTester) NewUnitedDeploymentManager(name string) *UnitedDeploymentManager

Sep 1, 2023

Changes in this version

type CloneSetTester

+ func (t *CloneSetTester) DeletePod(name string) error

+ type ImageListPullJobTester struct

+ func NewImageListPullJobTester(c clientset.Interface, kc kruiseclientset.Interface) *ImageListPullJobTester

+ func (tester *ImageListPullJobTester) CreateJob(job *appsv1alpha1.ImageListPullJob) error

+ func (tester *ImageListPullJobTester) DeleteAllJobs(ns string) error

+ func (tester *ImageListPullJobTester) DeleteJob(job *appsv1alpha1.ImageListPullJob) error

+ func (tester *ImageListPullJobTester) FailNodeImageFast(name string) error

+ func (tester *ImageListPullJobTester) GetJob(job *appsv1alpha1.ImageListPullJob) (*appsv1alpha1.ImageListPullJob, error)

+ func (tester *ImageListPullJobTester) ListJobs(ns string) (*appsv1alpha1.ImageListPullJobList, error)

Apr 3, 2024

Changes in this version

type ImagePullJobTester

+ func (tester *ImagePullJobTester) CreateSecret(secret *v1.Secret) (*v1.Secret, error)

+ func (tester *ImagePullJobTester) ListSyncedSecrets(source *v1.Secret) ([]v1.Secret, error)

+ func (tester *ImagePullJobTester) UpdateSecret(secret *v1.Secret) (*v1.Secret, error)

Mar 20, 2023

Changes in this version

+ var StatefulSetLikeTestKind = kruiseappsv1beta1.GroupVersion.WithKind("StatefulSetLikeTest")

type CloneSetTester

+ func (t *CloneSetTester) ListPVCForCloneSet() (pvcs []*v1.PersistentVolumeClaim, err error)

type PersistentPodStateTester

+ func (s *PersistentPodStateTester) AddStatefulsetLikeClusterRoleConf()

+ func (s *PersistentPodStateTester) CheckStatefulsetLikeCRDExist() (bool, error)

+ func (s *PersistentPodStateTester) CreateDynamicWatchWhiteList(gvks []schema.GroupVersionKind)

+ func (s *PersistentPodStateTester) CreateStatefulsetLike(sts *StatefulSetLikeTest) *StatefulSetLikeTest

+ func (s *PersistentPodStateTester) CreateStatefulsetLikeCRD(namespace string)

+ func (s *PersistentPodStateTester) CreateStatefulsetLikePods(sts *StatefulSetLikeTest)

+ func (s *PersistentPodStateTester) ListPodsInNamespace(ns string) ([]*corev1.Pod, error)

+ func (s *PersistentPodStateTester) NewBaseStatefulsetLikeTest(namespace string) *StatefulSetLikeTest

+ func (s *PersistentPodStateTester) UpdateStatefulsetLikeStatus(sts *StatefulSetLikeTest)

+ type StatefulSetLikeStatusSpec struct

+ ReadyReplicas int32

+ Replicas int32

+ type StatefulSetLikeTest struct

+ Spec StatefulSetLikeTestSpec

+ Status StatefulSetLikeStatusSpec

+ func (in *StatefulSetLikeTest) DeepCopy() *StatefulSetLikeTest

+ func (in *StatefulSetLikeTest) DeepCopyInto(out *StatefulSetLikeTest)

+ func (in *StatefulSetLikeTest) DeepCopyObject() runtime.Object

+ type StatefulSetLikeTestList struct

+ Items []StatefulSetLikeTest

+ type StatefulSetLikeTestSpec struct

+ Replicas *int32

+ Selector *metav1.LabelSelector

+ Template corev1.PodTemplateSpec

Sep 29, 2022

Changes in this version

type DaemonSetTester

+ func (t *DaemonSetTester) GetNodesToDaemonPods(label map[string]string) (map[string][]*v1.Pod, error)

+ type PodProbeMarkerTester struct

+ func NewPodProbeMarkerTester(c clientset.Interface, kc kruiseclientset.Interface) *PodProbeMarkerTester

+ func (s *PodProbeMarkerTester) CreateStatefulSet(sts *apps.StatefulSet)

+ func (s *PodProbeMarkerTester) ListActivePods(ns string) ([]*corev1.Pod, error)

+ func (s *PodProbeMarkerTester) NewBaseStatefulSet(namespace string) *apps.StatefulSet

+ func (s *PodProbeMarkerTester) NewPodProbeMarker(ns string) []appsv1alpha1.PodProbeMarker

+ func (s *PodProbeMarkerTester) WaitForStatefulSetRunning(sts *apps.StatefulSet)

type PodUnavailableBudgetTester

+ func (t *PodUnavailableBudgetTester) WaitForDeploymentReadyAndRunning(deployment *apps.Deployment)

type WorkloadSpreadTester

+ func (t *WorkloadSpreadTester) CreateService(svc *corev1.Service)

+ func (t *WorkloadSpreadTester) CreateStatefulSet(statefulSet *appsv1alpha1.StatefulSet) *appsv1beta1.StatefulSet

+ func (t *WorkloadSpreadTester) NewBaseHeadlessStatefulSet(namespace string) (*appsv1alpha1.StatefulSet, *corev1.Service)

+ func (t *WorkloadSpreadTester) WaitForStatefulSetRunning(statefulSet *appsv1beta1.StatefulSet)

Jun 7, 2022

Changes in this version

+ type PersistentPodStateTester struct

+ func NewPersistentPodStateTester(c clientset.Interface, kc kruiseclientset.Interface) *PersistentPodStateTester

+ func (s *PersistentPodStateTester) CreateStatefulset(sts *appsv1.StatefulSet)

+ func (s *PersistentPodStateTester) ListPodsInKruiseSts(sts *appsv1.StatefulSet) ([]*corev1.Pod, error)

+ func (s *PersistentPodStateTester) NewBaseStatefulset(namespace string) *appsv1.StatefulSet

+ func (s *PersistentPodStateTester) UpdateStatefulset(sts *appsv1.StatefulSet)

+ func (s *PersistentPodStateTester) WaitForStatefulsetRunning(sts *appsv1.StatefulSet)

Mar 24, 2022

Changes in this version

+ func GetDefaultStorageClassName(c clientset.Interface) (string, error)

+ func SkipIfNoDefaultStorageClass(c clientset.Interface) bool

type DaemonSetTester

+ func (t *DaemonSetTester) GetPod(name string) (*v1.Pod, error)

+ func (t *DaemonSetTester) PatchPod(name string, patchType types.PatchType, patch []byte) (*v1.Pod, error)

+ func (t *DaemonSetTester) SortPodNames(podList *v1.PodList) []string

Jan 21, 2022

Changes in this version

type ResourceDistributionTester

+ func (s *ResourceDistributionTester) DeleteSecret(namespace, name string) error

+ func (s *ResourceDistributionTester) UpdateSecret(secret *corev1.Secret) error

type SidecarSetTester

+ func (t *SidecarSetTester) ListControllerRevisions(sidecarSet *appsv1alpha1.SidecarSet) []*apps.ControllerRevision

Dec 14, 2021

Changes in this version

type CloneSetTester

+ func (s *CloneSetTester) GetSelectorPods(namespace string, selector *metav1.LabelSelector) ([]v1.Pod, error)

+ func (t *CloneSetTester) ListPodsForCloneSet(name string) (pods []*v1.Pod, err error)

type DaemonSetTester

+ func (t *DaemonSetTester) CheckDaemonReady(dsName string) func() (bool, error)

+ func (t *DaemonSetTester) CheckPodHasNotRecreate(oldPods, newPods []v1.Pod) bool

+ func (t *DaemonSetTester) CheckPodStayInNode(oldNodeList *v1.NodeList, newNodeList *v1.NodeList) func() (bool, error)

+ func (t *DaemonSetTester) DaemonPodHasReadinessGate(pods []v1.Pod) bool

+ func (t *DaemonSetTester) GetNewPodsToCheckImage(label map[string]string, newImage string) func() (bool, error)

+ type DeploymentTester struct

+ func NewDeploymentTester(c clientset.Interface, ns string) *DeploymentTester

+ func (t *DeploymentTester) CreateDeployment(dp *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (t *DeploymentTester) GetDeployment(name string) (*appsv1.Deployment, error)

+ func (t *DeploymentTester) GetSelectorPods(namespace string, selector *metav1.LabelSelector) ([]v1.Pod, error)

+ func (t *DeploymentTester) NewDeployment(name string, replicas int32) *appsv1.Deployment

+ type EphemeralJobTester struct

+ func NewEphemeralJobTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *EphemeralJobTester

+ func (s *EphemeralJobTester) DeleteDeployment(deployment *apps.Deployment)

+ func (s *EphemeralJobTester) DeleteDeployments(namespace string)

+ func (s *EphemeralJobTester) DeleteEphemeralJobs(ns string)

+ func (s *EphemeralJobTester) WaitForDeploymentDeleted(deployment *apps.Deployment)

+ func (s *EphemeralJobTester) WaitForDeploymentRunning(deployment *apps.Deployment)

+ func (t *EphemeralJobTester) CheckEphemeralJobExist(job *appsv1alpha1.EphemeralJob) bool

+ func (t *EphemeralJobTester) CreateEphemeralJob(job *appsv1alpha1.EphemeralJob) *appsv1alpha1.EphemeralJob

+ func (t *EphemeralJobTester) CreateTestDeployment(randStr string, replicas int32, containers []v1.Container) (pods []*v1.Pod)

+ func (t *EphemeralJobTester) CreateTestEphemeralJob(randStr string, replicas, Parallelism int32, selector metav1.LabelSelector, ...) *appsv1alpha1.EphemeralJob

+ func (t *EphemeralJobTester) DeleteEphemeralJob(job *appsv1alpha1.EphemeralJob)

+ func (t *EphemeralJobTester) GetEphemeralJob(name string) (*appsv1alpha1.EphemeralJob, error)

+ func (t *EphemeralJobTester) GetPodsByEjob(name string) ([]*v1.Pod, error)

+ func (t *EphemeralJobTester) WaitForEphemeralJobCreated(job *appsv1alpha1.EphemeralJob)

+ func (t *EphemeralJobTester) WaitForEphemeralJobDeleted(job *appsv1alpha1.EphemeralJob)

+ type PodUnavailableBudgetTester struct

+ func NewPodUnavailableBudgetTester(c clientset.Interface, kc kruiseclientset.Interface) *PodUnavailableBudgetTester

+ func (s *PodUnavailableBudgetTester) NewBaseCloneSet(namespace string) *appsv1alpha1.CloneSet

+ func (s *PodUnavailableBudgetTester) NewBaseDeployment(namespace string) *apps.Deployment

+ func (t *PodUnavailableBudgetTester) CreateCloneSet(cloneset *appsv1alpha1.CloneSet) *appsv1alpha1.CloneSet

+ func (t *PodUnavailableBudgetTester) CreateDeployment(deployment *apps.Deployment)

+ func (t *PodUnavailableBudgetTester) CreatePub(pub *policyv1alpha1.PodUnavailableBudget) *policyv1alpha1.PodUnavailableBudget

+ func (t *PodUnavailableBudgetTester) DeleteCloneSets(namespace string)

+ func (t *PodUnavailableBudgetTester) DeleteDeployments(namespace string)

+ func (t *PodUnavailableBudgetTester) DeletePubs(namespace string)

+ func (t *PodUnavailableBudgetTester) NewBasePub(namespace string) *policyv1alpha1.PodUnavailableBudget

+ func (t *PodUnavailableBudgetTester) WaitForCloneSetDeleted(cloneset *appsv1alpha1.CloneSet)

+ func (t *PodUnavailableBudgetTester) WaitForCloneSetMinReadyAndRunning(cloneSets []*appsv1alpha1.CloneSet, minReady int32)

+ func (t *PodUnavailableBudgetTester) WaitForCloneSetRunning(cloneset *appsv1alpha1.CloneSet)

+ func (t *PodUnavailableBudgetTester) WaitForDeploymentDeleted(deployment *apps.Deployment)

+ func (t *PodUnavailableBudgetTester) WaitForDeploymentMinReadyAndRunning(deployments []*apps.Deployment, minReady int32)

+ func (t *PodUnavailableBudgetTester) WaitForDeploymentRunning(deployment *apps.Deployment)

+ func (t *PodUnavailableBudgetTester) WaitForPubCreated(pub *policyv1alpha1.PodUnavailableBudget)

+ type ResourceDistributionTester struct

+ func NewResourceDistributionTester(c clientset.Interface, kc kruiseclientset.Interface) *ResourceDistributionTester

+ func (s *ResourceDistributionTester) CreateNamespaces(namespaces ...*corev1.Namespace)

+ func (s *ResourceDistributionTester) CreateResourceDistribution(resourceDistribution *appsv1alpha1.ResourceDistribution) *appsv1alpha1.ResourceDistribution

+ func (s *ResourceDistributionTester) CreateSecretResources(secrets ...*corev1.Secret)

+ func (s *ResourceDistributionTester) DeleteNamespace(namespace *corev1.Namespace)

+ func (s *ResourceDistributionTester) DeleteNamespaces(nsPrefix string)

+ func (s *ResourceDistributionTester) DeleteResourceDistribution(resourceDistribution *appsv1alpha1.ResourceDistribution)

+ func (s *ResourceDistributionTester) DeleteResourceDistributions(nsPrefix string)

+ func (s *ResourceDistributionTester) GetNamespaceForDistributor(targets *appsv1alpha1.ResourceDistributionTargets) (matchedNamespaces, unmatchedNamespaces sets.String, err error)

+ func (s *ResourceDistributionTester) GetResourceDistribution(name string, mustExistAssertion bool) (*appsv1alpha1.ResourceDistribution, error)

+ func (s *ResourceDistributionTester) GetSecret(namespace, name string, mustExistAssertion bool) (*corev1.Secret, error)

+ func (s *ResourceDistributionTester) NewBaseNamespace(namespace string) *corev1.Namespace

+ func (s *ResourceDistributionTester) NewBaseResourceDistribution(nsPrefix string) *appsv1alpha1.ResourceDistribution

+ func (s *ResourceDistributionTester) UpdateNamespace(namespace *corev1.Namespace)

+ func (s *ResourceDistributionTester) UpdateResourceDistribution(resourceDistribution *appsv1alpha1.ResourceDistribution)

+ func (s *ResourceDistributionTester) WaitForNamespaceCreated(namespace *corev1.Namespace)

+ func (s *ResourceDistributionTester) WaitForNamespaceDeleted(namespace *corev1.Namespace)

+ func (s *ResourceDistributionTester) WaitForResourceDistributionCreated(name string, timeout time.Duration)

+ func (s *ResourceDistributionTester) WaitForResourceDistributionDeleted(resourceDistribution *appsv1alpha1.ResourceDistribution)

+ func (s *ResourceDistributionTester) WaitForSecretCreated(namespace, name string, timeout time.Duration)

type SidecarSetTester

+ func (s *SidecarSetTester) WaitForSidecarSetMinReadyAndUpgrade(sidecarSet *appsv1alpha1.SidecarSet, ...)

type WorkloadSpreadTester

+ func (t *WorkloadSpreadTester) GetCloneSet(namespace, name string) (*appsv1alpha1.CloneSet, error)

+ func (t *WorkloadSpreadTester) GetWorkloadSpread(namespace, name string) (*appsv1alpha1.WorkloadSpread, error)

Nov 12, 2021

Changes in this version

+ type WorkloadSpreadTester struct

+ C clientset.Interface

+ func NewWorkloadSpreadTester(c clientset.Interface, kc kruiseclientset.Interface) *WorkloadSpreadTester

+ func (t *WorkloadSpreadTester) CreateCloneSet(cloneSet *appsv1alpha1.CloneSet) *appsv1alpha1.CloneSet

+ func (t *WorkloadSpreadTester) CreateDeployment(deployment *appsv1.Deployment) *appsv1.Deployment

+ func (t *WorkloadSpreadTester) CreateJob(job *batchv1.Job) *batchv1.Job

+ func (t *WorkloadSpreadTester) CreateWorkloadSpread(workloadSpread *appsv1alpha1.WorkloadSpread) *appsv1alpha1.WorkloadSpread

+ func (t *WorkloadSpreadTester) GetSelectorPods(namespace string, selector *metav1.LabelSelector) ([]corev1.Pod, error)

+ func (t *WorkloadSpreadTester) NewBaseCloneSet(namespace string) *appsv1alpha1.CloneSet

+ func (t *WorkloadSpreadTester) NewBaseDeployment(namespace string) *appsv1.Deployment

+ func (t *WorkloadSpreadTester) NewBaseJob(namespace string) *batchv1.Job

+ func (t *WorkloadSpreadTester) NewWorkloadSpread(namespace, name string, targetRef *appsv1alpha1.TargetReference, ...) *appsv1alpha1.WorkloadSpread

+ func (t *WorkloadSpreadTester) SetNodeLabel(c clientset.Interface, node *corev1.Node, key, value string)

+ func (t *WorkloadSpreadTester) UpdateCloneSet(cloneSet *appsv1alpha1.CloneSet)

+ func (t *WorkloadSpreadTester) UpdateDeployment(deployment *appsv1.Deployment)

+ func (t *WorkloadSpreadTester) UpdateWorkloadSpread(workloadSpread *appsv1alpha1.WorkloadSpread)

+ func (t *WorkloadSpreadTester) WaitForCloneSetRunReplicas(cloneSet *appsv1alpha1.CloneSet, replicas int32)

+ func (t *WorkloadSpreadTester) WaitForCloneSetRunning(cloneSet *appsv1alpha1.CloneSet)

+ func (t *WorkloadSpreadTester) WaitForDeploymentRunning(deployment *appsv1.Deployment)

+ func (t *WorkloadSpreadTester) WaitForWorkloadSpreadRunning(ws *appsv1alpha1.WorkloadSpread)

+ func (t *WorkloadSpreadTester) WaitJobCompleted(job *batchv1.Job)

+ func (t *WorkloadSpreadTester) WaiteCloneSetUpdate(cloneSet *appsv1alpha1.CloneSet)

+ func (t *WorkloadSpreadTester) WaiteDeploymentUpdate(deployment *appsv1.Deployment)

Sep 6, 2021

Changes in this version

type BroadcastJobTester

+ func (t *BroadcastJobTester) WaitForBroadcastJobCreated(job *appsv1alpha1.BroadcastJob)

type NodeTester

+ func (t *NodeTester) ListNodesWithFake() ([]*v1.Node, error)

May 19, 2021

Changes in this version

+ const DaemonSetColorLabel

+ const DaemonSetLabelPrefix

+ const DaemonSetNameLabel

+ const DaemonSetRetryPeriod

+ const DaemonSetRetryTimeout

+ const NewImage

+ const OldImage

type CloneSetTester

+ func (t *CloneSetTester) DeleteCloneSet(name string) error

+ func (t *CloneSetTester) ListImagePullJobsForCloneSet(name string) (jobs []*appsv1alpha1.ImagePullJob, err error)

+ func (t *CloneSetTester) UpdateCloneSet(name string, fn func(cs *appsv1alpha1.CloneSet)) error

+ type ContainerRecreateTester struct

+ func NewContainerRecreateTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *ContainerRecreateTester

+ func (t *ContainerRecreateTester) CleanAllTestResources() error

+ func (t *ContainerRecreateTester) CreateCRR(crr *appsv1alpha1.ContainerRecreateRequest) (*appsv1alpha1.ContainerRecreateRequest, error)

+ func (t *ContainerRecreateTester) CreateTestCloneSetAndGetPods(randStr string, replicas int32, containers []v1.Container) (pods []*v1.Pod)

+ func (t *ContainerRecreateTester) GetCRR(name string) (*appsv1alpha1.ContainerRecreateRequest, error)

+ func (t *ContainerRecreateTester) GetPod(name string) (*v1.Pod, error)

+ type DaemonSetTester struct

+ func NewDaemonSetTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *DaemonSetTester

+ func (t *DaemonSetTester) CanScheduleOnNode(node v1.Node, ds *appsv1alpha1.DaemonSet) bool

+ func (t *DaemonSetTester) CheckDaemonPodOnNodes(ds *appsv1alpha1.DaemonSet, nodeNames []string) func() (bool, error)

+ func (t *DaemonSetTester) CheckDaemonStatus(dsName string) error

+ func (t *DaemonSetTester) CheckRunningOnAllNodes(ds *appsv1alpha1.DaemonSet) func() (bool, error)

+ func (t *DaemonSetTester) CheckRunningOnNoNodes(ds *appsv1alpha1.DaemonSet) func() (bool, error)

+ func (t *DaemonSetTester) ClearDaemonSetNodeLabels(c clientset.Interface) error

+ func (t *DaemonSetTester) CreateDaemonSet(ds *appsv1alpha1.DaemonSet) (*appsv1alpha1.DaemonSet, error)

+ func (t *DaemonSetTester) DeleteDaemonSet(namespace, name string)

+ func (t *DaemonSetTester) GetDaemonSet(name string) (*appsv1alpha1.DaemonSet, error)

+ func (t *DaemonSetTester) ListDaemonPods(label map[string]string) (*v1.PodList, error)

+ func (t *DaemonSetTester) NewDaemonSet(name string, label map[string]string, image string, ...) *appsv1alpha1.DaemonSet

+ func (t *DaemonSetTester) PatchDaemonSet(name string, patchType types.PatchType, patch []byte) (*appsv1alpha1.DaemonSet, error)

+ func (t *DaemonSetTester) SchedulableNodes(ds *appsv1alpha1.DaemonSet) []string

+ func (t *DaemonSetTester) SeparateDaemonSetNodeLabels(labels map[string]string) (map[string]string, map[string]string)

+ func (t *DaemonSetTester) SetDaemonSetNodeLabels(nodeName string, labels map[string]string) (*v1.Node, error)

+ func (t *DaemonSetTester) UpdateDaemonSet(name string, fn func(ds *appsv1alpha1.DaemonSet)) error

+ func (t *DaemonSetTester) WaitFailedDaemonPodDeleted(pod *v1.Pod) func() (bool, error)

+ func (t *DaemonSetTester) WaitForDaemonSetDeleted(namespace, name string)

type Framework

+ ApiExtensionsClientSet apiextensionsclientset.Interface

type SidecarSetTester

+ func (s *SidecarSetTester) NewBaseCloneSet(namespace string) *appsv1alpha1.CloneSet

+ func (t *SidecarSetTester) CreateCloneSet(cloneset *appsv1alpha1.CloneSet) *appsv1alpha1.CloneSet

+ func (t *SidecarSetTester) WaitForCloneSetRunning(cloneset *appsv1alpha1.CloneSet)

Apr 8, 2021

Changes in this version

+ const E2eFakeKey

+ type BroadcastJobTester struct

+ func NewBroadcastJobTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *BroadcastJobTester

+ func (t *BroadcastJobTester) CreateBroadcastJob(job *appsv1alpha1.BroadcastJob) (*appsv1alpha1.BroadcastJob, error)

+ func (t *BroadcastJobTester) GetBroadcastJob(name string) (*appsv1alpha1.BroadcastJob, error)

+ func (t *BroadcastJobTester) GetPodsOfJob(job *appsv1alpha1.BroadcastJob) (pods []*v1.Pod, err error)

+ type NodeTester struct

+ func NewNodeTester(c clientset.Interface) *NodeTester

+ func (t *NodeTester) CreateFakeNode(randStr string) (node *v1.Node, err error)

+ func (t *NodeTester) DeleteFakeNode(randStr string) error

+ func (t *NodeTester) ListRealNodesWithFake(randStr string) ([]*v1.Node, error)

Mar 4, 2021

Changes in this version

+ const FakeNodeImageLabelKey

+ func ExpectEqual(actual interface{}, extra interface{}, explain ...interface{})

+ type CloneSetTester struct

+ func NewCloneSetTester(c clientset.Interface, kc kruiseclientset.Interface, ns string) *CloneSetTester

+ func (t *CloneSetTester) CreateCloneSet(cs *appsv1alpha1.CloneSet) (*appsv1alpha1.CloneSet, error)

+ func (t *CloneSetTester) GetCloneSet(name string) (*appsv1alpha1.CloneSet, error)

+ func (t *CloneSetTester) NewCloneSet(name string, replicas int32) *appsv1alpha1.CloneSet

type Framework

+ AfterEachActions []func()

+ type ImagePullJobTester struct

+ func NewImagePullJobTester(c clientset.Interface, kc kruiseclientset.Interface) *ImagePullJobTester

+ func (tester *ImagePullJobTester) CreateJob(job *appsv1alpha1.ImagePullJob) error

+ func (tester *ImagePullJobTester) DeleteAllJobs(ns string) error

+ func (tester *ImagePullJobTester) DeleteJob(job *appsv1alpha1.ImagePullJob) error

+ func (tester *ImagePullJobTester) GetJob(job *appsv1alpha1.ImagePullJob) (*appsv1alpha1.ImagePullJob, error)

+ func (tester *ImagePullJobTester) ListJobs(ns string) (*appsv1alpha1.ImagePullJobList, error)

+ type NodeImageTester struct

+ func NewNodeImageTester(c clientset.Interface, kc kruiseclientset.Interface) *NodeImageTester

+ func (tester *NodeImageTester) CreateFakeNodeImageIfNotPresent() error

+ func (tester *NodeImageTester) DeleteFakeNodeImage() error

+ func (tester *NodeImageTester) ExpectNodes() ([]*v1.Node, error)

+ func (tester *NodeImageTester) GetNodeImage(name string) (*appsv1alpha1.NodeImage, error)

+ func (tester *NodeImageTester) IsImageInSpec(image, nodeName string) (bool, error)

+ func (tester *NodeImageTester) ListNodeImages() (*appsv1alpha1.NodeImageList, error)

+ type SidecarSetTester struct

+ func NewSidecarSetTester(c clientset.Interface, kc kruiseclientset.Interface) *SidecarSetTester

+ func (s *SidecarSetTester) CreateDeployment(deployment *apps.Deployment)

+ func (s *SidecarSetTester) CreateSidecarSet(sidecarSet *appsv1alpha1.SidecarSet) *appsv1alpha1.SidecarSet

+ func (s *SidecarSetTester) DeleteDeployment(deployment *apps.Deployment)

+ func (s *SidecarSetTester) DeleteDeployments(namespace string)

+ func (s *SidecarSetTester) DeleteSidecarSet(sidecarSet *appsv1alpha1.SidecarSet)

+ func (s *SidecarSetTester) DeleteSidecarSets()

+ func (s *SidecarSetTester) GetSelectorPods(namespace string, selector *metav1.LabelSelector) ([]corev1.Pod, error)

+ func (s *SidecarSetTester) NewBaseDeployment(namespace string) *apps.Deployment

+ func (s *SidecarSetTester) NewBaseSidecarSet() *appsv1alpha1.SidecarSet

+ func (s *SidecarSetTester) UpdatePod(pod *corev1.Pod)

+ func (s *SidecarSetTester) UpdateSidecarSet(sidecarSet *appsv1alpha1.SidecarSet)

+ func (s *SidecarSetTester) WaitForDeploymentDeleted(deployment *apps.Deployment)

+ func (s *SidecarSetTester) WaitForDeploymentRunning(deployment *apps.Deployment)

+ func (s *SidecarSetTester) WaitForSidecarSetCreated(sidecarSet *appsv1alpha1.SidecarSet)

+ func (s *SidecarSetTester) WaitForSidecarSetDeleted(sidecarSet *appsv1alpha1.SidecarSet)

+ func (s *SidecarSetTester) WaitForSidecarSetUpgradeComplete(sidecarSet *appsv1alpha1.SidecarSet, ...)

Aug 2, 2019

Changes in this version

+ const ClaimBindingTimeout

+ const ClaimDeletingTimeout

+ const ClaimProvisionShortTimeout

+ const ClaimProvisionTimeout

+ const DefaultNamespaceDeletionTimeout

+ const NamespaceCleanupTimeout

+ const NodeReadyInitialTimeout

+ const PVBindingTimeout

+ const PVDeletingTimeout

+ const PVReclaimingTimeout

+ const PodDeleteTimeout

+ const PodEventTimeout

+ const PodListTimeout

+ const PodReadyBeforeTimeout

+ const PodStartShortTimeout

+ const PodStartTimeout

+ const Poll

+ const RestartNodeReadyAgainTimeout

+ const RestartPodReadyAgainTimeout

+ const ServiceAccountProvisionTimeout

+ const ServiceStartTimeout

+ const SingleCallTimeout

+ const StatefulPodTimeout

+ const StatefulSetPoll

+ const StatefulSetTimeout

+ var NotReadyTaintTemplate = &v1.Taint

+ var RunID = uuid.NewUUID()

+ var UnreachableTaintTemplate = &v1.Taint

+ func AfterReadingAllFlags(t *TestContextType)

+ func AllNodesReady(c clientset.Interface, timeout time.Duration) error

+ func ConformanceIt(text string, body interface{}, timeout ...float64) bool

+ func CreatePV(c clientset.Interface, pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ func CreateServiceSpec(serviceName, externalName string, isHeadless bool, selector map[string]string) *v1.Service

+ func CreateStatefulSetService(name string, labels map[string]string) *v1.Service

+ func CreateTestingNS(baseName string, c clientset.Interface, labels map[string]string) (*v1.Namespace, error)

+ func DeleteAllStatefulSets(c clientset.Interface, kc kruiseclientset.Interface, ns string)

+ func DumpAllNamespaceInfo(c clientset.Interface, namespace string)

+ func DumpDebugInfo(c clientset.Interface, ns string)

+ func DumpEventsInNamespace(eventsLister EventsLister, namespace string)

+ func ExpectNoError(err error, explain ...interface{})

+ func ExpectNoErrorWithOffset(offset int, err error, explain ...interface{})

+ func ExpectNoErrorWithRetries(fn func() error, maxRetries int, explain ...interface{})

+ func Failf(format string, args ...interface{})

+ func FailfWithOffset(offset int, format string, args ...interface{})

+ func FilterNodes(nodeList *v1.NodeList, fn func(node v1.Node) bool)

+ func GetReadySchedulableNodesOrDie(c clientset.Interface) (nodes *v1.NodeList)

+ func HandleFlags()

+ func IsNodeConditionSetAsExpected(node *v1.Node, conditionType v1.NodeConditionType, wantTrue bool) bool

+ func IsNodeConditionSetAsExpectedSilent(node *v1.Node, conditionType v1.NodeConditionType, wantTrue bool) bool

+ func IsNodeConditionUnset(node *v1.Node, conditionType v1.NodeConditionType) bool

+ func KruiseDescribe(text string, body func()) bool

+ func KubectlCmd(args ...string) *exec.Cmd

+ func LoadClientset() (*clientset.Clientset, error)

+ func LoadConfig() (*restclient.Config, error)

+ func Logf(format string, args ...interface{})

+ func NewStatefulSet(name, ns, governingSvcName string, replicas int32, ...) *appsv1alpha1.StatefulSet

+ func NewStatefulSetPVC(name string) v1.PersistentVolumeClaim

+ func NewStatefulSetScale(ss *appsv1alpha1.StatefulSet) *appsV1beta2.Scale

+ func RegisterClusterFlags()

+ func RegisterCommonFlags()

+ func RegisterNodeFlags()

+ func RegisterProvider(name string, factory Factory)

+ func RemoveCleanupAction(p CleanupActionHandle)

+ func RestclientConfig(kubeContext string) (*clientcmdapi.Config, error)

+ func RunCleanupActions()

+ func RunHostCmd(ns, name, cmd string) (string, error)

+ func RunHostCmdWithRetries(ns, name, cmd string, interval, timeout time.Duration) (string, error)

+ func RunKubectl(args ...string) (string, error)

+ func RunKubectlOrDie(args ...string) string

+ func Skipf(format string, args ...interface{})

+ func UpdateStatefulSetWithRetries(kc kruiseclientset.Interface, namespace, name string, ...) (statefulSet *appsv1alpha1.StatefulSet, err error)

+ func WaitForDefaultServiceAccountInNamespace(c clientset.Interface, namespace string) error

+ func WaitForPodCondition(c clientset.Interface, ns, podName, desc string, timeout time.Duration, ...) error

+ func WaitForPodNameRunningInNamespace(c clientset.Interface, podName, namespace string) error

+ func WaitForPodRunningInNamespace(c clientset.Interface, pod *v1.Pod) error

+ func WaitTimeoutForPodRunningInNamespace(c clientset.Interface, podName, namespace string, timeout time.Duration) error

+ type CleanupActionHandle *int

+ func AddCleanupAction(fn func()) CleanupActionHandle

+ type ClientConfigGetter func() (*restclient.Config, error)

+ type CloudConfig struct

+ APIEndpoint string

+ Cluster string

+ ClusterIPRange string

+ ClusterTag string

+ ConfigFile string

+ MasterName string

+ MasterTag string

+ MultiMaster bool

+ MultiZone bool

+ Network string

+ NodeInstanceGroup string

+ NodeTag string

+ NumNodes int

+ ProjectID string

+ Provider ProviderInterface

+ Region string

+ Zone string

+ type CreateTestingNSFn func(baseName string, c clientset.Interface, labels map[string]string) (*v1.Namespace, error)

+ type EventsLister func(opts metav1.ListOptions, ns string) (*v1.EventList, error)

+ type Factory func() (ProviderInterface, error)

+ type Framework struct

+ BaseName string

+ ClientSet clientset.Interface

+ DynamicClient dynamic.Interface

+ KruiseClientSet kruiseclientset.Interface

+ Namespace *v1.Namespace

+ NamespaceDeletionTimeout time.Duration

+ Options Options

+ ScalesGetter scaleclient.ScalesGetter

+ SkipNamespaceCreation bool

+ SkipPrivilegedPSPBinding bool

+ TestSummaries []TestDataSummary

+ UniqueName string

+ func NewDefaultFramework(baseName string) *Framework

+ func NewFramework(baseName string, options Options, client clientset.Interface) *Framework

+ func (f *Framework) AddNamespacesToDelete(namespaces ...*v1.Namespace)

+ func (f *Framework) AfterEach()

+ func (f *Framework) BeforeEach()

+ func (f *Framework) CreateNamespace(baseName string, labels map[string]string) (*v1.Namespace, error)

+ func (f *Framework) PodClient() *PodClient

+ func (f *Framework) WaitForPodRunning(podName string) error

+ type KubectlBuilder struct

+ func NewKubectlCommand(args ...string) *KubectlBuilder

+ func (b *KubectlBuilder) WithEnv(env []string) *KubectlBuilder

+ func (b *KubectlBuilder) WithTimeout(t <-chan time.Time) *KubectlBuilder

+ func (b KubectlBuilder) Exec() (string, error)

+ func (b KubectlBuilder) ExecOrDie() string

+ func (b KubectlBuilder) WithStdinData(data string) *KubectlBuilder

+ func (b KubectlBuilder) WithStdinReader(reader io.Reader) *KubectlBuilder

+ type NodeTestContextType struct

+ ExtraEnvs map[string]string

+ ImageDescription string

+ NodeConformance bool

+ NodeE2E bool

+ NodeName string

+ PrepullImages bool

+ SystemSpecName string

+ type NullProvider struct

+ func (n NullProvider) CleanupServiceResources(c clientset.Interface, loadBalancerName, region, zone string)

+ func (n NullProvider) CreatePD(zone string) (string, error)

+ func (n NullProvider) CreatePVSource(zone, diskName string) (*v1.PersistentVolumeSource, error)

+ func (n NullProvider) DeletePD(pdName string) error

+ func (n NullProvider) DeletePVSource(pvSource *v1.PersistentVolumeSource) error

+ func (n NullProvider) EnableAndDisableInternalLB() (enable, disable func(svc *v1.Service))

+ func (n NullProvider) EnsureLoadBalancerResourcesDeleted(ip, portRange string) error

+ func (n NullProvider) FrameworkAfterEach(f *Framework)

+ func (n NullProvider) FrameworkBeforeEach(f *Framework)

+ func (n NullProvider) GetGroupNodes(group string) ([]string, error)

+ func (n NullProvider) GroupSize(group string) (int, error)

+ func (n NullProvider) LoadBalancerSrcRanges() []string

+ func (n NullProvider) ResizeGroup(string, int32) error

+ type Options struct

+ ClientBurst int

+ ClientQPS float32

+ GroupVersion *schema.GroupVersion

+ type PodClient struct

+ func (c *PodClient) Update(name string, updateFn func(pod *v1.Pod))

+ type ProviderInterface interface

+ CleanupServiceResources func(c clientset.Interface, loadBalancerName, region, zone string)

+ CreatePD func(zone string) (string, error)

+ CreatePVSource func(zone, diskName string) (*v1.PersistentVolumeSource, error)

+ DeletePD func(pdName string) error

+ DeletePVSource func(pvSource *v1.PersistentVolumeSource) error

+ EnableAndDisableInternalLB func() (enable, disable func(svc *v1.Service))

+ EnsureLoadBalancerResourcesDeleted func(ip, portRange string) error

+ FrameworkAfterEach func(f *Framework)

+ FrameworkBeforeEach func(f *Framework)

+ GetGroupNodes func(group string) ([]string, error)

+ GroupSize func(group string) (int, error)

+ LoadBalancerSrcRanges func() []string

+ ResizeGroup func(group string, size int32) error

+ func SetupProviderConfig(providerName string) (ProviderInterface, error)

+ type StatefulSetTester struct

+ func NewStatefulSetTester(c clientset.Interface, kc kruiseclientset.Interface) *StatefulSetTester

+ func (s *StatefulSetTester) BreakHTTPProbe(ss *appsv1alpha1.StatefulSet) error

+ func (s *StatefulSetTester) BreakPodHTTPProbe(ss *appsv1alpha1.StatefulSet, pod *v1.Pod) error

+ func (s *StatefulSetTester) CheckHostname(ss *appsv1alpha1.StatefulSet) error

+ func (s *StatefulSetTester) CheckMount(ss *appsv1alpha1.StatefulSet, mountPath string) error

+ func (s *StatefulSetTester) CheckServiceName(ss *appsv1alpha1.StatefulSet, expectedServiceName string) error

+ func (s *StatefulSetTester) ConfirmStatefulPodCount(count int, ss *appsv1alpha1.StatefulSet, timeout time.Duration, hard bool)

+ func (s *StatefulSetTester) CreateStatefulSet(manifestPath, ns string) *appsv1alpha1.StatefulSet

+ func (s *StatefulSetTester) DeleteStatefulPodAtIndex(index int, ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) ExecInStatefulPods(ss *appsv1alpha1.StatefulSet, cmd string) error

+ func (s *StatefulSetTester) GetPodList(ss *appsv1alpha1.StatefulSet) *v1.PodList

+ func (s *StatefulSetTester) GetStatefulSet(namespace, name string) *appsv1alpha1.StatefulSet

+ func (s *StatefulSetTester) PauseNewPods(ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) Restart(ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) RestoreHTTPProbe(ss *appsv1alpha1.StatefulSet) error

+ func (s *StatefulSetTester) RestorePodHTTPProbe(ss *appsv1alpha1.StatefulSet, pod *v1.Pod) error

+ func (s *StatefulSetTester) ResumeNextPod(ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) Saturate(ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) Scale(ss *appsv1alpha1.StatefulSet, count int32) (*appsv1alpha1.StatefulSet, error)

+ func (s *StatefulSetTester) SetHTTPProbe(ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) SortStatefulPods(pods *v1.PodList)

+ func (s *StatefulSetTester) UpdateReplicas(ss *appsv1alpha1.StatefulSet, count int32)

+ func (s *StatefulSetTester) VerifyPodAtIndex(index int, ss *appsv1alpha1.StatefulSet, verify VerifyStatefulPodFunc)

+ func (s *StatefulSetTester) WaitForPartitionedRollingUpdate(set *appsv1alpha1.StatefulSet) (*appsv1alpha1.StatefulSet, *v1.PodList)

+ func (s *StatefulSetTester) WaitForPodNotReady(set *appsv1alpha1.StatefulSet, podName string) (*appsv1alpha1.StatefulSet, *v1.PodList)

+ func (s *StatefulSetTester) WaitForPodReady(set *appsv1alpha1.StatefulSet, podName string) (*appsv1alpha1.StatefulSet, *v1.PodList)

+ func (s *StatefulSetTester) WaitForRollingUpdate(set *appsv1alpha1.StatefulSet) (*appsv1alpha1.StatefulSet, *v1.PodList)

+ func (s *StatefulSetTester) WaitForRunning(numPodsRunning, numPodsReady int32, ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) WaitForRunningAndNotReady(numStatefulPods int32, ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) WaitForRunningAndReady(numStatefulPods int32, ss *appsv1alpha1.StatefulSet)

+ func (s *StatefulSetTester) WaitForState(ss *appsv1alpha1.StatefulSet, ...)

+ func (s *StatefulSetTester) WaitForStatus(set *appsv1alpha1.StatefulSet) *appsv1alpha1.StatefulSet

+ func (s *StatefulSetTester) WaitForStatusReadyReplicas(ss *appsv1alpha1.StatefulSet, expectedReplicas int32)

+ func (s *StatefulSetTester) WaitForStatusReplicas(ss *appsv1alpha1.StatefulSet, expectedReplicas int32)

+ type TestContextType struct

+ AllowGatheringProfiles bool

+ AllowedNotReadyNodes int

+ CertDir string

+ CleanStart bool

+ CloudConfig CloudConfig

+ ClusterDNSDomain string

+ ClusterMonitoringMode string

+ ContainerRuntime string

+ ContainerRuntimeEndpoint string

+ ContainerRuntimePidFile string

+ ContainerRuntimeProcessName string

+ CreateTestingNS CreateTestingNSFn

+ DeleteNamespace bool

+ DeleteNamespaceOnFailure bool

+ DisableLogDump bool

+ DockershimCheckpointDir string

+ DumpLogsOnFailure bool

+ EnablePrometheusMonitoring bool

+ EtcdUpgradeStorage string

+ EtcdUpgradeVersion string

+ FeatureGates map[string]bool

+ GCEUpgradeScript string

+ GatherKubeSystemResourceUsageData string

+ GatherLogsSizes bool

+ GatherMetricsAfterTest string

+ GatherSuiteMetricsAfterTest bool

+ Host string

+ ImageServiceEndpoint string

+ IncludeClusterAutoscalerMetrics bool

+ IngressUpgradeImage string

+ KubeAPIContentType string

+ KubeConfig string

+ KubeContext string

+ KubeVolumeDir string

+ KubectlPath string

+ KubernetesAnywherePath string

+ LogexporterGCSPath string

+ MasterOSDistro string

+ MinStartupPods int

+ NodeOSDistro string

+ NodeSchedulableTimeout time.Duration

+ OutputDir string

+ OutputPrintType string

+ Prefix string

+ Provider string

+ RepoRoot string

+ ReportDir string

+ ReportPrefix string

+ SystemDaemonsetStartupTimeout time.Duration

+ SystemPodsStartupTimeout time.Duration

+ SystemdServices string

+ Tooling string

+ VerifyServiceAccount bool

+ var TestContext TestContextType

+ type TestDataSummary interface

+ PrintHumanReadable func() string

+ PrintJSON func() string

+ SummaryKind func() string

+ type VerifyStatefulPodFunc func(*v1.Pod)