kubernetes/staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1beta1_test.go

func TestV1beta1NewFromConfig(t *testing.T) { … }

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 *authorizationv1beta1.SubjectAccessReview) { … }

func (m *mockV1beta1Service) Allow()              { … }

func (m *mockV1beta1Service) Deny()               { … }

func (m *mockV1beta1Service) HTTPStatusCode() int { … }

// newV1beta1Authorizer creates a temporary kubeconfig file from the provided arguments and attempts to load
// a new WebhookAuthorizer from it.
func newV1beta1Authorizer(callbackURL string, clientCert, clientKey, ca []byte, cacheTime time.Duration) (*WebhookAuthorizer, error) { … }

func TestV1beta1TLSConfig(t *testing.T) { … }

type recorderV1beta1Service …

func (rec *recorderV1beta1Service) Review(r *authorizationv1beta1.SubjectAccessReview) { … }

func (rec *recorderV1beta1Service) Last() (authorizationv1beta1.SubjectAccessReview, error) { … }

func (rec *recorderV1beta1Service) HTTPStatusCode() int { … }

func TestV1beta1Webhook(t *testing.T) { … }

// TestWebhookCache verifies that error responses from the server are not
// cached, but successful responses are.
func TestV1beta1WebhookCache(t *testing.T) { … }