observe

Documentation

Index

• type ResourceVersionObserver
  • func NewClusterObserver(versioner storage.Versioner, watchers []rest.Watcher, successThreshold int) ResourceVersionObserver

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.