Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ResourceVersionObserver ¶
type ResourceVersionObserver interface { // ObserveResourceVersion waits until the given resourceVersion is observed, up to the specified timeout. ObserveResourceVersion(resourceVersion string, timeout time.Duration) error }
func NewClusterObserver ¶
func NewClusterObserver(versioner storage.Versioner, watchers []rest.Watcher, successThreshold int) ResourceVersionObserver
NewClusterObserver returns a ResourceVersionObserver that watches for the specified resourceVersion on all of the provided watchers. If at least successThreshold watchers observe the resourceVersion within the timeout, no error is returned.