var apiAuds … type V1beta1Service … // NewV1beta1TestServer wraps a V1beta1Service as an httptest.Server. func NewV1beta1TestServer(s V1beta1Service, cert, key, caCert []byte) (*httptest.Server, error) { … } type mockV1beta1Service … func (m *mockV1beta1Service) Review(r *authenticationv1beta1.TokenReview) { … } func (m *mockV1beta1Service) Allow() { … } func (m *mockV1beta1Service) Deny() { … } func (m *mockV1beta1Service) HTTPStatusCode() int { … } // newV1beta1TokenAuthenticator creates a temporary kubeconfig file from the provided // arguments and attempts to load a new WebhookTokenAuthenticator from it. func newV1beta1TokenAuthenticator(serverURL string, clientCert, clientKey, ca []byte, cacheTime time.Duration, implicitAuds authenticator.Audiences) (authenticator.Token, error) { … } func TestV1beta1TLSConfig(t *testing.T) { … } type recorderV1beta1Service … func (rec *recorderV1beta1Service) Review(r *authenticationv1beta1.TokenReview) { … } func (rec *recorderV1beta1Service) HTTPStatusCode() int { … } func TestV1beta1WebhookTokenAuthenticator(t *testing.T) { … } type authenticationV1beta1UserInfo … func (a *authenticationV1beta1UserInfo) GetName() string { … } func (a *authenticationV1beta1UserInfo) GetUID() string { … } func (a *authenticationV1beta1UserInfo) GetGroups() []string { … } func (a *authenticationV1beta1UserInfo) GetExtra() map[string][]string { … } var _ … // TestWebhookCache verifies that error responses from the server are not // cached, but successful responses are. It also ensures that the webhook // call is retried on 429 and 500+ errors func TestV1beta1WebhookCacheAndRetry(t *testing.T) { … }
Codebase Browser
kubernetes