Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + type ClusterWatcher struct + func NewClusterWatcher(pCtx context.Context, clusterId string, storage storage.Storage, zk zk.Zk, ...) *ClusterWatcher + func (cw *ClusterWatcher) Start(event chan *MetricEvent) + func (cw *ClusterWatcher) Stop() + type EventType int + const EventDynamicUpd + const EventMetricDel + const EventMetricUpd + func (et EventType) String() string + type MetricEvent struct + First bool + ID string + Last bool + Meta map[string]btypes.ObjectMeta + Metric *types.Metric + Type EventType + type StorageApplicationIf struct + Data string + type StorageCollectorIf struct + Data *types.ApplicationCollectorCfg + type StorageMetricIf struct + Data *types.Metric + ID string + type Watcher struct + func NewWatcher(storage storage.Storage, zk zk.Zk, config *config.Config) *Watcher + func (w *Watcher) Start() chan *MetricEvent + func (w *Watcher) Stop()