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 …
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) { … }
func (e *transformTest) createJob(name, namespace string) (*batchv1.Job, error) { … }
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) { … }