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

const testTimeoutClientUsername …

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

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

type invocation …

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

type timeoutRecorder …

// Reset zeros out all counts
func (i *timeoutRecorder) Reset() { … }

// MarkerReceived records the specified markers were received and returns the set of received markers
func (i *timeoutRecorder) MarkerReceived(markers ...string) sets.String { … }

func (i *timeoutRecorder) RecordInvocation(call invocation) { … }

func newTimeoutWebhookHandler(recorder *timeoutRecorder) http.Handler { … }

var timeoutMarkerFixture …