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

// helper function to reduce stuttering
func testPop(f *DeltaFIFO) testFifoObject { … }

type literalListerGetter …

var _ …

// ListKeys just calls kl.
func (kl literalListerGetter) ListKeys() []string { … }

// GetByKey returns the key if it exists in the list returned by kl.
func (kl literalListerGetter) GetByKey(key string) (interface{ … }

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

// TestDeltaFIFO_replaceWithDeleteDeltaIn tests that a `Sync` delta for an
// object `O` with ID `X` is added when .Replace is called and `O` is among the
// replacement objects even if the DeltaFIFO already stores in terminal position
// a delta of type `Delete` for ID `X`. Not adding the `Sync` delta causes
// SharedIndexInformers to miss `O`'s create notification, see https://github.com/kubernetes/kubernetes/issues/83810
// for more details.
func TestDeltaFIFO_replaceWithDeleteDeltaIn(t *testing.T) { … }

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

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

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

type rvAndXfrm …

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

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

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

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

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

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

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

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

// TestDeltaFIFO_ReplaceMakesDeletionsReplaced is the same as the above test, but
// ensures that a Replaced DeltaType is emitted.
func TestDeltaFIFO_ReplaceMakesDeletionsReplaced(t *testing.T) { … }

// TestDeltaFIFO_ReplaceDeltaType checks that passing EmitDeltaTypeReplaced
// means that Replaced is correctly emitted.
func TestDeltaFIFO_ReplaceDeltaType(t *testing.T) { … }

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

// pop2 captures both parameters, unlike Pop().
func pop2[T any](queue Queue) (T, bool) { … }

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

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

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

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

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

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

func BenchmarkDeltaFIFOListKeys(b *testing.B) { … }