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() { … }
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 { … }