// LoadFromManifests loads .yaml or .json manifest files and returns // all items that it finds in them. It supports all items for which // there is a factory registered in factories and .yaml files with // multiple items separated by "---". Files are accessed via the // "testfiles" package, which means they can come from a file system // or be built into the binary. // // LoadFromManifests has some limitations: // - aliases are not supported (i.e. use serviceAccountName instead of the deprecated serviceAccount, // https://kubernetes.io/docs/reference/kubernetes-api/workload-resources/pod-v1) // and silently ignored // - the latest stable API version for each item is used, regardless of what // is specified in the manifest files func LoadFromManifests(files ...string) ([]interface{ … } func visitManifests(cb func([]byte) error, files ...string) error { … } // PatchItems modifies the given items in place such that each test // gets its own instances, to avoid conflicts between different tests // and between tests and normal deployments. // // This is done by: // - creating namespaced items inside the test's namespace // - changing the name of non-namespaced items like ClusterRole // // PatchItems has some limitations: // - only some common items are supported, unknown ones trigger an error // - only the latest stable API version for each item is supported func PatchItems(f *framework.Framework, driverNamespace *v1.Namespace, items ...interface{ … } // CreateItems creates the items. Each of them must be an API object // of a type that is registered in Factory. // // It returns either a cleanup function or an error, but never both. // // Cleaning up after a test can be triggered in two ways: // - the test invokes the returned cleanup function, // usually in an AfterEach // - the test suite terminates, potentially after // skipping the test's AfterEach (https://github.com/onsi/ginkgo/issues/222) // // PatchItems has the some limitations as LoadFromManifests: // - only some common items are supported, unknown ones trigger an error // - only the latest stable API version for each item is supported func CreateItems(ctx context.Context, f *framework.Framework, ns *v1.Namespace, items ...interface{ … } // CreateFromManifests is a combination of LoadFromManifests, // PatchItems, patching with an optional custom function, // and CreateItems. func CreateFromManifests(ctx context.Context, f *framework.Framework, driverNamespace *v1.Namespace, patch func(item interface{ … } type What … // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new What. func (in *What) DeepCopy() *What { … } // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. func (in *What) DeepCopyInto(out *What) { … } // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object. func (in *What) DeepCopyObject() runtime.Object { … } // GetObjectKind returns the ObjectKind schema func (in *What) GetObjectKind() schema.ObjectKind { … } type ItemFactory … // describeItem always returns a string that describes the item, // usually by calling out to cache.MetaNamespaceKeyFunc which // concatenates namespace (if set) and name. If that fails, the entire // item gets converted to a string. func describeItem(item interface{ … } var errorItemNotSupported … var factories … // PatchName makes the name of some item unique by appending the // generated unique name. func PatchName(f *framework.Framework, item *string) { … } // PatchNamespace moves the item into the test's namespace. Not // all items can be namespaced. For those, the name also needs to be // patched. func PatchNamespace(f *framework.Framework, driverNamespace *v1.Namespace, item *string) { … } func patchItemRecursively(f *framework.Framework, driverNamespace *v1.Namespace, item interface{ … } type serviceAccountFactory … func (f *serviceAccountFactory) New() runtime.Object { … } func (*serviceAccountFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type clusterRoleFactory … func (f *clusterRoleFactory) New() runtime.Object { … } func (*clusterRoleFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type clusterRoleBindingFactory … func (f *clusterRoleBindingFactory) New() runtime.Object { … } func (*clusterRoleBindingFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type roleFactory … func (f *roleFactory) New() runtime.Object { … } func (*roleFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type roleBindingFactory … func (f *roleBindingFactory) New() runtime.Object { … } func (*roleBindingFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type serviceFactory … func (f *serviceFactory) New() runtime.Object { … } func (*serviceFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type statefulSetFactory … func (f *statefulSetFactory) New() runtime.Object { … } func (*statefulSetFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type deploymentFactory … func (f *deploymentFactory) New() runtime.Object { … } func (*deploymentFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type daemonSetFactory … func (f *daemonSetFactory) New() runtime.Object { … } func (*daemonSetFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type replicaSetFactory … func (f *replicaSetFactory) New() runtime.Object { … } func (*replicaSetFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type storageClassFactory … func (f *storageClassFactory) New() runtime.Object { … } func (*storageClassFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type volumeAttributesClassFactory … func (f *volumeAttributesClassFactory) New() runtime.Object { … } func (*volumeAttributesClassFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type csiDriverFactory … func (f *csiDriverFactory) New() runtime.Object { … } func (*csiDriverFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type secretFactory … func (f *secretFactory) New() runtime.Object { … } func (*secretFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } type customResourceDefinitionFactory … func (f *customResourceDefinitionFactory) New() runtime.Object { … } func (*customResourceDefinitionFactory) Create(ctx context.Context, f *framework.Framework, ns *v1.Namespace, i interface{ … } // PrettyPrint returns a human-readable representation of an item. func PrettyPrint(item interface{ … } // patchContainerImages replaces the specified Container Registry with a custom // one provided via the KUBE_TEST_REPO_LIST env variable func patchContainerImages(containers []v1.Container) error { … }
Codebase Browser
kubernetes