kubernetes/staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

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

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

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

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

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

// TestWatchFromNonZero tests that
// - watch from non-0 should just watch changes after given version
func TestWatchFromNoneZero(t *testing.T) { … }

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

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

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

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

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

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

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

// TestWatchDispatchBookmarkEvents makes sure that
// setting allowWatchBookmarks query param against
// etcd implementation doesn't have any effect.
func TestWatchDispatchBookmarkEvents(t *testing.T) { … }

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

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

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

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

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

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

// TestWatchErrorIncorrectConfiguration checks if an error
// will be returned when the storage hasn't been properly
// initialised for watch requests
func TestWatchErrorIncorrectConfiguration(t *testing.T) { … }

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

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

type etcdClientKVWrapper …

func newEtcdClientKVWrapper(kv clientv3.KV) *etcdClientKVWrapper { … }

func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { … }

func initStoreData(ctx context.Context, store storage.Interface) ([]interface{ … }