kubernetes/staging/src/k8s.io/client-go/tools/record/events_cache_test.go

func makeObjectReference(kind, name, namespace string) v1.ObjectReference { … }

func makeEvent(reason, message string, involvedObject v1.ObjectReference) v1.Event { … }

func makeEvents(num int, template v1.Event) []v1.Event { … }

func makeUniqueEvents(num int) []v1.Event { … }

func makeSimilarEvents(num int, template v1.Event, messagePrefix string) []v1.Event { … }

func setCount(event v1.Event, count int) v1.Event { … }

func validateEvent(messagePrefix string, actualEvent *v1.Event, expectedEvent *v1.Event, t *testing.T) (*v1.Event, error) { … }

// TestEventAggregatorByReasonFunc ensures that two events are aggregated if they vary only by event.message
func TestEventAggregatorByReasonFunc(t *testing.T) { … }

// TestEventAggregatorByReasonMessageFunc validates the proper output for an aggregate message
func TestEventAggregatorByReasonMessageFunc(t *testing.T) { … }

// TestEventCorrelator validates proper counting, aggregation of events
func TestEventCorrelator(t *testing.T) { … }

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