kubernetes/plugin/pkg/admission/eventratelimit/admission_test.go

const qps …

const eventKind …

const nonEventKind …

// attributesForRequest generates the admission.Attributes that for the specified request
func attributesForRequest(rq request) admission.Attributes { … }

type request …

func newRequest(kind string) request { … }

func newEventRequest() request { … }

func newNonEventRequest() request { … }

func (r request) withNamespace(namespace string) request { … }

func (r request) withEvent(event *api.Event) request { … }

func (r request) withEventComponent(component string) request { … }

func (r request) withDryRun(dryRun bool) request { … }

func (r request) withUser(name string) request { … }

func (r request) blocked() request { … }

// withDelay will adjust the clock to simulate the specified delay, in seconds
func (r request) withDelay(delayInSeconds int) request { … }

// createSourceAndObjectKeyInclusionRequests creates a series of requests that can be used
// to test that a particular part of the event is included in the source+object key
func createSourceAndObjectKeyInclusionRequests(eventFactory func(label string) *api.Event) []request { … }

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