NewManager returns a new manager.

NewObserver creates and starts an Observer.

WatchClusterHealthChange returns a Source fed with generic events targeting clusters whose health has changed between 2 observations.

ObserverIntervalAnnotation is the name of the annotation used to set the observation interval for a cluster.

Manager for a set of observers.

Observer regularly requests an ES endpoint for cluster state, in a thread-safe way.

Settings for the Observer configuration.

OnObservation is a function that gets executed when a new state is observed.