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

func init() { … }

type testObject …

func (o testObject) GetObjectKind() schema.ObjectKind { … }

func (o testObject) DeepCopyObject() runtime.Object   { … }

func (o testObject) GetResourceVersion() string       { … }

func withCounter(w cache.Watcher) (*uint32, cache.Watcher) { … }

func makeTestEvent(rv int) watch.Event { … }

func arrayToChannel(array []watch.Event) chan watch.Event { … }

// parseResourceVersionOrDie is test-only that code simulating the server and thus can interpret resourceVersion
func parseResourceVersionOrDie(resourceVersion string) uint64 { … }

func fromRV(resourceVersion string, array []watch.Event) []watch.Event { … }

func closeAfterN(n int, source chan watch.Event) chan watch.Event { … }

type unexpectedError …

var _ …

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

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

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