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.
Source Files