const DefaultNamespaceDeletionTimeout … const defaultServiceAccountName … var NewFrameworkExtensions … type Framework … type DumpAllNamespaceInfoAction … type TestDataSummary … type Options … // NewFrameworkWithCustomTimeouts makes a framework with custom timeouts. // For timeout values that are zero the normal default value continues to // be used. func NewFrameworkWithCustomTimeouts(baseName string, timeouts *TimeoutContext) *Framework { … } // NewDefaultFramework makes a new framework and sets up a BeforeEach which // initializes the framework instance. It cleans up with a DeferCleanup, // which runs last, so a AfterEach in the test still has a valid framework // instance. func NewDefaultFramework(baseName string) *Framework { … } // NewFramework creates a test framework. func NewFramework(baseName string, options Options, client clientset.Interface) *Framework { … } // BeforeEach gets a client and makes a namespace. func (f *Framework) BeforeEach(ctx context.Context) { … } func (f *Framework) dumpNamespaceInfo(ctx context.Context) { … } // printSummaries prints summaries of tests. func printSummaries(summaries []TestDataSummary, testBaseName string) { … } // AfterEach deletes the namespace, after reading its events. func (f *Framework) AfterEach(ctx context.Context) { … } // DeleteNamespace can be used to delete a namespace. Additionally it can be used to // dump namespace information so as it can be used as an alternative of framework // deleting the namespace towards the end. func (f *Framework) DeleteNamespace(ctx context.Context, name string) { … } // CreateNamespace creates a namespace for e2e testing. func (f *Framework) CreateNamespace(ctx context.Context, baseName string, labels map[string]string) (*v1.Namespace, error) { … } func firstNonEmptyPSaLevelOrRestricted(levelConfig ...admissionapi.Level) string { … } // createSecretFromDockerConfig creates a secret using the private image registry credentials. // The credentials are provided by --e2e-docker-config-file flag. func (f *Framework) createSecretFromDockerConfig(ctx context.Context, namespace string) (*v1.Secret, error) { … } // RecordFlakeIfError records flakeness info if error happens. // NOTE: This function is not used at any places yet, but we are in progress for https://github.com/kubernetes/kubernetes/issues/66239 which requires this. Please don't remove this. func (f *Framework) RecordFlakeIfError(err error, optionalDescription ...interface{ … } // AddNamespacesToDelete adds one or more namespaces to be deleted when the test // completes. func (f *Framework) AddNamespacesToDelete(namespaces ...*v1.Namespace) { … } // ClientConfig an externally accessible method for reading the kube client config. func (f *Framework) ClientConfig() *rest.Config { … } type KubeUser … type KubeCluster … type KubeConfig … // FindUser returns user info which is the specified user name. func (kc *KubeConfig) FindUser(name string) *KubeUser { … } // FindCluster returns cluster info which is the specified cluster name. func (kc *KubeConfig) FindCluster(name string) *KubeCluster { … } type PodStateVerification … type ClusterVerification … // NewClusterVerification creates a new cluster verification. func (f *Framework) NewClusterVerification(namespace *v1.Namespace, filter PodStateVerification) *ClusterVerification { … } func passesPodNameFilter(pod v1.Pod, name string) bool { … } func passesVerifyFilter(pod v1.Pod, verify func(p v1.Pod) (bool, error)) (bool, error) { … } func passesPhasesFilter(pod v1.Pod, validPhases []v1.PodPhase) bool { … } // filterLabels returns a list of pods which have labels. func filterLabels(ctx context.Context, selectors map[string]string, cli clientset.Interface, ns string) (*v1.PodList, error) { … } // filter filters pods which pass a filter. It can be used to compose // the more useful abstractions like ForEach, WaitFor, and so on, which // can be used directly by tests. func (p *PodStateVerification) filter(ctx context.Context, c clientset.Interface, namespace *v1.Namespace) ([]v1.Pod, error) { … } // WaitFor waits for some minimum number of pods to be verified, according to the PodStateVerification // definition. func (cl *ClusterVerification) WaitFor(ctx context.Context, atLeast int, timeout time.Duration) ([]v1.Pod, error) { … } // WaitForOrFail provides a shorthand WaitFor with failure as an option if anything goes wrong. func (cl *ClusterVerification) WaitForOrFail(ctx context.Context, atLeast int, timeout time.Duration) { … } // ForEach runs a function against every verifiable pod. Be warned that this doesn't wait for "n" pods to verify, // so it may return very quickly if you have strict pod state requirements. // // For example, if you require at least 5 pods to be running before your test will pass, // its smart to first call "clusterVerification.WaitFor(5)" before you call clusterVerification.ForEach. func (cl *ClusterVerification) ForEach(ctx context.Context, podFunc func(v1.Pod)) error { … }
Codebase Browser
kubernetes