kubernetes/staging/src/k8s.io/client-go/tools/cache/fifo_test.go

func testFifoObjectKeyFunc(obj interface{ … }

type testFifoObject …

func mkFifoObj(name string, val interface{ … }

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

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

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

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

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

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

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

// TestFIFO_PopShouldUnblockWhenClosed checks that any blocking Pop on an empty queue
// should unblock and return after Close is called.
func TestFIFO_PopShouldUnblockWhenClosed(t *testing.T) { … }