kubernetes/staging/src/k8s.io/client-go/tools/watch/informerwatcher_test.go

// TestEventProcessorExit is expected to timeout if the event processor fails
// to exit when stopped.
func TestEventProcessorExit(t *testing.T) { … }

type apiInt …

func (apiInt) GetObjectKind() schema.ObjectKind { … }

func (apiInt) DeepCopyObject() runtime.Object   { … }

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

type byEventTypeAndName …

func (a byEventTypeAndName) Len() int      { … }

func (a byEventTypeAndName) Swap(i, j int) { … }

func (a byEventTypeAndName) Less(i, j int) bool { … }

func newTestSecret(name, key, value string) *corev1.Secret { … }

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

// TestInformerWatcherDeletedFinalStateUnknown tests the code path when `DeleteFunc`
// in `NewIndexerInformerWatcher` receives a `cache.DeletedFinalStateUnknown`
// object from the underlying `DeltaFIFO`. The triggering condition is described
// at https://github.com/kubernetes/kubernetes/blob/dc39ab2417bfddcec37be4011131c59921fdbe98/staging/src/k8s.io/client-go/tools/cache/delta_fifo.go#L736-L739.
//
// Code from @liggitt
func TestInformerWatcherDeletedFinalStateUnknown(t *testing.T) { … }