kubernetes/test/e2e/apimachinery/watch.go

const watchConfigMapLabelKey …

const multipleWatchersLabelValueA …

const multipleWatchersLabelValueB …

const fromResourceVersionLabelValue …

const watchRestartedLabelValue …

const toBeChangedLabelValue …

var _ …

func watchConfigMaps(ctx context.Context, f *framework.Framework, resourceVersion string, labels ...string) (watch.Interface, error) { … }

func int64ptr(i int) *int64 { … }

func setConfigMapData(cm *v1.ConfigMap, key, value string) { … }

func expectEvent(w watch.Interface, eventType watch.EventType, object runtime.Object) { … }

func expectNoEvent(w watch.Interface, eventType watch.EventType, object runtime.Object) { … }

func waitForEvent(w watch.Interface, expectType watch.EventType, expectObject runtime.Object, duration time.Duration) (watch.Event, bool) { … }

func waitForNextConfigMapEvent(watch watch.Interface) *v1.ConfigMap { … }

const createEvent …

const updateEvent …

const deleteEvent …

func produceConfigMapEvents(ctx context.Context, f *framework.Framework, stopc <-chan struct{ … }