const exitCodeEnvVar … const outputEnvVar … const outputFileEnvVar … type roundTripperFunc … func (f roundTripperFunc) RoundTrip(req *http.Request) (*http.Response, error) { … } type syncedHeaderValues … func (s *syncedHeaderValues) append(values []string) { … } func (s *syncedHeaderValues) get() [][]string { … } type execPluginCall … type execPluginMetrics … func (m *execPluginMetrics) Increment(exitCode int, callStatus string) { … } var execPluginMetricsComparer … type execPluginClientTestData … func execPluginClientTests(t *testing.T, unauthorizedCert, unauthorizedKey []byte, clientAuthorizedToken, clientCertFileName, clientKeyFileName string) []execPluginClientTestData { … } func v1beta1TestsFromV1Tests(v1Tests []execPluginClientTestData) []execPluginClientTestData { … } func TestExecPluginViaClient(t *testing.T) { … } func captureMetrics(t *testing.T) *execPluginMetrics { … } var objectMetaSansResourceVersionComparer … type oldNew … var oldNewComparer … type informerSpy … func (is *informerSpy) OnAdd(obj interface{ … } func (is *informerSpy) OnUpdate(old, new interface{ … } func (is *informerSpy) OnDelete(obj interface{ … } func (is *informerSpy) clear() { … } // waitForEvents waits for adds, updates, and deletes to be populated with at least one event. func (is *informerSpy) waitForEvents(t *testing.T, wantEvents bool) { … } func TestExecPluginViaInformer(t *testing.T) { … } type execPlugin … func newExecPlugin(t *testing.T) *execPlugin { … } func (e *execPlugin) config() *clientcmdapi.ExecConfig { … } func (e *execPlugin) rotateToken(newToken string, lifetime time.Duration) { … } func TestExecPluginRotationViaInformer(t *testing.T) { … } func startTestServer(t *testing.T) (result *kubeapiservertesting.TestServer, clientAuthorizedToken string, clientCertFileName string, clientKeyFileName string) { … } func writeTokenFile(t *testing.T, goodToken string) string { … } func read(t *testing.T, fileName string) string { … } func basicAuthHeaderValue(username, password string) string { … } func x509KeyPair(certPEMBlock, keyPEMBlock []byte, leaf bool) *tls.Certificate { … } func loadX509KeyPair(certFile, keyFile string) *tls.Certificate { … } func createNamespace(ctx context.Context, t *testing.T, client clientset.Interface) *corev1.Namespace { … } func startConfigMapInformer(ctx context.Context, t *testing.T, client clientset.Interface, namespace string) (cache.SharedIndexInformer, *informerSpy) { … } func waitForInformerSync(ctx context.Context, t *testing.T, informer cache.SharedIndexInformer, wantSynced bool, lastSyncResourceVersion string) { … } func createUpdateDeleteConfigMap(ctx context.Context, t *testing.T, cms v1.ConfigMapInterface) (created, updated, deleted *corev1.ConfigMap) { … } func assertInformerEvents(t *testing.T, informerSpy *informerSpy, created, updated, deleted interface{ … } func TestExecPluginGlobalCache(t *testing.T) { … } func execPluginMemoryAddress(t *testing.T, config *rest.Config, i int) string { … }
Codebase Browser
kubernetes