kubernetes/test/integration/controlplane/transformation/transformation_test.go

const secretKey …

const secretVal …

const encryptionConfigFileName …

const testNamespace …

const testSecret …

const testConfigmap …

const metricsPrefix …

const configMapKey …

const configMapVal …

const oldAESCBCKey …

const oldSecret …

const oldSecretVal …

type unSealSecret …

type transformTest …

func newTransformTest(tb testing.TB, transformerConfigYAML string, reload bool, configDir string, storageConfig *storagebackend.Config) (*transformTest, error) { … }

var startTestServerLock …

// startTestServerLocked prevents parallel calls to kubeapiservertesting.StartTestServer because it messes with global state.
func startTestServerLocked(t ktesting.TB, instanceOptions *kubeapiservertesting.TestServerInstanceOptions, customFlags []string, storageConfig *storagebackend.Config) (result kubeapiservertesting.TestServer, err error) { … }

func (e *transformTest) cleanUp() { … }

func (e *transformTest) shutdownAPIServer() { … }

func (e *transformTest) runResource(l kubeapiservertesting.Logger, unSealSecretFunc unSealSecret, expectedEnvelopePrefix,
	group,
	version,
	resource,
	name,
	namespaceName string,
) { … }

func (e *transformTest) benchmark(b *testing.B) { … }

func (e *transformTest) getETCDPathForResource(storagePrefix, group, resource, name, namespaceName string) string { … }

func (e *transformTest) getRawSecretFromETCD() ([]byte, error) { … }

func (e *transformTest) getEncryptionOptions(reload bool) []string { … }

func (e *transformTest) createEncryptionConfig() (
	filePathForEncryptionConfig string,
	err error,
) { … }

func (e *transformTest) getEncryptionConfig() (*apiserverv1.ProviderConfiguration, error) { … }

func (e *transformTest) createNamespace(name string) (*corev1.Namespace, error) { … }

func (e *transformTest) createSecret(name, namespace string) (*corev1.Secret, error) { … }

func (e *transformTest) createConfigMap(name, namespace string) (*corev1.ConfigMap, error) { … }

// create jobs
func (e *transformTest) createJob(name, namespace string) (*batchv1.Job, error) { … }

// create deployment
func (e *transformTest) createDeployment(name, namespace string) (*appsv1.Deployment, error) { … }

func gvr(group, version, resource string) schema.GroupVersionResource { … }

func createResource(client dynamic.Interface, gvr schema.GroupVersionResource, ns string) (*unstructured.Unstructured, error) { … }

func inplaceUpdateResource(client dynamic.Interface, gvr schema.GroupVersionResource, ns string, obj *unstructured.Unstructured) (*unstructured.Unstructured, error) { … }

func getStubObj(gvr schema.GroupVersionResource) (*unstructured.Unstructured, error) { … }

func (e *transformTest) createPod(namespace string, dynamicInterface dynamic.Interface) (*unstructured.Unstructured, error) { … }

func (e *transformTest) deletePod(namespace string, dynamicInterface dynamic.Interface) error { … }

func (e *transformTest) inplaceUpdatePod(namespace string, obj *unstructured.Unstructured, dynamicInterface dynamic.Interface) (*unstructured.Unstructured, error) { … }

func (e *transformTest) readRawRecordFromETCD(path string) (*clientv3.GetResponse, error) { … }

func (e *transformTest) writeRawRecordToETCD(path string, data []byte) (*clientv3.PutResponse, error) { … }

func (e *transformTest) printMetrics() error { … }

func mustBeHealthy(t kubeapiservertesting.Logger, checkName, wantBodyContains string, clientConfig *rest.Config, excludes ...string) { … }

func mustBeUnHealthy(t kubeapiservertesting.Logger, checkName, wantBodyContains string, clientConfig *rest.Config, excludes ...string) { … }

func mustNotHaveLivez(t kubeapiservertesting.Logger, checkName, wantBodyContains string, clientConfig *rest.Config, excludes ...string) { … }

func getHealthz(checkName string, clientConfig *rest.Config, excludes ...string) (string, bool, error) { … }

func getLivez(checkName string, clientConfig *rest.Config, excludes ...string) (string, bool, error) { … }