kubernetes/test/integration/apiserver/admissionwebhook/reinvocation_test.go

const testReinvocationClientUsername …

const auditPolicy …

// TestWebhookReinvocationPolicyWithWatchCache ensures that the admission webhook reinvocation policy is applied correctly with the watch cache enabled.
func TestWebhookReinvocationPolicyWithWatchCache(t *testing.T) { … }

// TestWebhookReinvocationPolicyWithoutWatchCache ensures that the admission webhook reinvocation policy is applied correctly without the watch cache enabled.
func TestWebhookReinvocationPolicyWithoutWatchCache(t *testing.T) { … }

func mutationAnnotationValue(configuration, webhook string, mutated bool) string { … }

func patchAnnotationValue(configuration, webhook string, patch string) string { … }

// testWebhookReinvocationPolicy ensures that the admission webhook reinvocation policy is applied correctly.
func testWebhookReinvocationPolicy(t *testing.T, watchCache bool) { … }

type invocationRecorder …

// Reset zeros out all counts and returns a channel that is closed when the first admission of the
// marker object is received.
func (i *invocationRecorder) Reset() chan struct{ … }

func (i *invocationRecorder) MarkerReceived() { … }

func (i *invocationRecorder) GetCount(path string) int { … }

func (i *invocationRecorder) IncrementCount(path string) { … }

func newReinvokeWebhookHandler(recorder *invocationRecorder) http.Handler { … }

func expectedAuditEvents(webhookMutationAnnotations, webhookPatchAnnotations map[string]string, namespace string) []utils.AuditEvent { … }

func newReinvocationMarkerFixture(namespace string) *corev1.Pod { … }