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

type testEventSink …

// CreateEvent records the event for testing.
func (t *testEventSink) Create(e *v1.Event) (*v1.Event, error) { … }

// UpdateEvent records the event for testing.
func (t *testEventSink) Update(e *v1.Event) (*v1.Event, error) { … }

// PatchEvent records the event for testing.
func (t *testEventSink) Patch(e *v1.Event, p []byte) (*v1.Event, error) { … }

type OnCreateFunc …

func OnCreateFactory(testCache map[string]*v1.Event, createEvent chan<- *v1.Event) OnCreateFunc { … }

type OnPatchFunc …

func OnPatchFactory(testCache map[string]*v1.Event, patchEvent chan<- *v1.Event) OnPatchFunc { … }

// newBroadcasterForTests creates a new broadcaster which produces per-test log
// output if StartStructuredLogging is used. Will be shut down automatically
// after the test.
func newBroadcasterForTests(tb testing.TB) EventBroadcaster { … }

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

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

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

func recorderWithFakeClock(t *testing.T, eventSource v1.EventSource, eventBroadcaster EventBroadcaster, clock clock.Clock) EventRecorder { … }

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

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

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

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

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

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