kubernetes/staging/src/k8s.io/kubelet/pkg/cri/streaming/request_cache_test.go

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

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

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

func newTestCache() (*requestCache, *testingclock.FakeClock) { … }

func assertCacheSize(t *testing.T, cache *requestCache, expectedSize int) { … }

var requestUID …

func nextRequest() interface{ … }